Carnac源码解析：WPF与Reactive Extensions的完美结合-拓冰建站

Carnac源码解析：WPF与Reactive Extensions的完美结合

【免费下载链接】carnacA utility to give some insight into how you use your keyboard项目地址: https://gitcode.com/gh_mirrors/car/carnac

Carnac是一款优秀的键盘输入可视化工具，它巧妙地将WPF桌面应用程序与Reactive Extensions响应式编程框架相结合，为开发者提供了一个实时显示键盘操作的教学演示工具。本文将深入解析Carnac源码，揭示WPF与Rx如何协同工作，打造出流畅的用户体验。

🎯 Carnac项目概述

Carnac是一个键盘记录和展示工具，主要用于演示、屏幕录制以及帮助用户更好地理解键盘使用方式。通过实时显示按键操作，Carnac让观众能够清晰地看到演示者的键盘输入，特别适合教学视频和技术分享场景。

🔧 核心架构设计

WPF作为用户界面框架

Carnac采用WPF（Windows Presentation Foundation）作为前端界面框架，提供了丰富的视觉呈现能力。WPF的数据绑定机制与MVVM模式完美契合，使得界面逻辑与业务逻辑清晰分离。

主要UI组件：

KeyShowView.xaml - 主显示窗口
PreferencesView.xaml - 设置界面
PositionOnMonitorSelector.xaml - 显示器位置选择器

Reactive Extensions实现响应式数据流

Reactive Extensions（Rx）是Carnac的核心技术栈，它通过可观察序列（Observable Sequences）处理异步事件流，将键盘输入、鼠标事件等转换为响应式数据流。

🚀 关键技术实现

1. 键盘事件捕获与处理

Carnac通过KeyProvider.cs类捕获系统级键盘事件。该类实现了IKeyProvider接口，将原始的键盘事件转换为可观察的数据流：

public IObservable<KeyPress> GetKeyStream() { return Observable.Create<KeyPress>(observer => { var sessionSwitchStreamSubscription = desktopLockEventService.GetSessionSwitchStream() .Subscribe(ss => { if (ss.Reason == SessionSwitchReason.SessionLock) winKeyPressed = false; }, observer.OnError); var keyStreamSubsription = Observable.Merge( new IObservable<InterceptKeyEventArgs>[2] { interceptKeysSource.GetKeyStream(), InterceptMouse.Current.GetKeyStream() }) .Select(DetectWindowsKey) .Where(k => k.KeyDirection == KeyDirection.Down) .Select(ToCarnacKeyPress) .Where(keypress => keypress != null) .Where(k => !passwordModeService.CheckPasswordMode(k.InterceptKeyEventArgs)) .Subscribe(observer); return new CompositeDisposable(sessionSwitchStreamSubscription, keyStreamSubsription); }); }

2. 响应式消息处理管道

KeysController.cs是连接Rx数据流与WPF界面的核心控制器。它通过Rx操作符构建了一个完整的消息处理管道：

public void Start() { var messageStream = messageProvider.GetMessageStream().Publish(); var addMessageSubscription = messageStream .ObserveOn(concurrencyService.MainThreadScheduler) .Subscribe(newMessage => { if (newMessage.Previous != null) { messages.Remove(newMessage.Previous); } messages.Add(newMessage); }); var fadeOutMessageSeq = messageStream .Delay(fadeOutDelay, concurrencyService.Default) .Select(m => m.FadeOut()) .Publish(); var fadeOutMessageSubscription = fadeOutMessageSeq .ObserveOn(concurrencyService.MainThreadScheduler) .Subscribe(msg => { var idx = messages.IndexOf(msg.Previous); if(idx>-1) messages[idx] = msg; }); var removeMessageSubscription = fadeOutMessageSeq .Delay(OneSecond, concurrencyService.Default) .ObserveOn(concurrencyService.MainThreadScheduler) .Subscribe(msg => messages.Remove(msg)); actionSubscription.Disposable = new CompositeDisposable( addMessageSubscription, fadeOutMessageSubscription, removeMessageSubscription, fadeOutMessageSeq.Connect(), messageStream.Connect()); }

3. WPF数据绑定与MVVM模式

KeyShowViewModel.cs作为视图模型，通过ObservableCollection与WPF界面进行数据绑定：

public class KeyShowViewModel : NotifyPropertyChanged { readonly ObservableCollection<Message> messages; readonly PopupSettings settings; public KeyShowViewModel(IObservable<Message> messageStream, IConcurrencyService concurrencyService, ISettingsProvider settingsProvider) { messages = new ObservableCollection<Message>(); settings = settingsProvider.GetSettings<PopupSettings>(); var keysController = new KeysController(messages, new MessageProvider(messageStream), concurrencyService, settingsProvider); keysController.Start(); } public ObservableCollection<Message> Messages { get { return messages; } } public PopupSettings Settings { get { return settings; } } }

📊 数据模型设计

Message.cs定义了Carnac的核心数据模型，封装了按键消息的所有信息：

public sealed class Message { readonly ReadOnlyCollection<string> textCollection; readonly ReadOnlyCollection<KeyPress> keys; readonly string processName; readonly ImageSource processIcon; readonly string shortcutName; readonly bool canBeMerged; readonly bool isShortcut; readonly bool isModifier; readonly bool isDeleting; readonly DateTime lastMessage; readonly Message previous; }

🔄 事件流处理策略

1. 事件合并与去重

Carnac通过Message.MergeIfNeeded方法智能合并连续的按键事件，避免界面闪烁：

public static Message MergeIfNeeded(Message previousMessage, Message newMessage) { if (ShouldCreateNewMessage(previousMessage, newMessage)) { return newMessage; } return previousMessage.Merge(newMessage); }

2. 淡出动画处理

通过Rx的Delay操作符实现消息的自动淡出效果：

var fadeOutMessageSeq = messageStream .Delay(fadeOutDelay, concurrencyService.Default) .Select(m => m.FadeOut()) .Publish();

3. 线程调度管理

使用ObserveOn确保UI更新在主线程执行：

.ObserveOn(concurrencyService.MainThreadScheduler)

🎨 WPF界面优化技巧

透明窗口与置顶显示

KeyShowView.xaml.cs通过Windows API实现透明窗口和置顶显示：

protected override void OnSourceInitialized(EventArgs e) { base.OnSourceInitialized(e); var hwnd = new WindowInteropHelper(this).Handle; Win32Methods.SetWindowExTransparentAndNotInWindowList(hwnd); // 窗口置顶逻辑 }

鼠标事件集成

Carnac不仅支持键盘事件，还集成了鼠标点击可视化功能：

void SetupMouseEvents() { if (m_GlobalHook == null) { m_GlobalHook = Hook.GlobalEvents(); } m_GlobalHook.MouseDown += OnMouseDown; m_GlobalHook.MouseMove += OnMouseMove; }

🔧 配置与扩展性

快捷键映射系统

Carnac支持自定义快捷键映射，配置文件位于Keymaps/目录，包括：

chrome.yml - Chrome浏览器快捷键
vscode.yml - VS Code编辑器快捷键
resharper.yml - ReSharper快捷键

进程过滤机制

通过正则表达式实现进程过滤，只显示特定应用程序的按键操作：

private bool ShouldFilterProcess(out Regex filterRegex) { filterRegex = null; if (settings?.ProcessFilterExpression != currentFilter) { currentFilter = settings?.ProcessFilterExpression; if (!string.IsNullOrEmpty(currentFilter)) { filterRegex = new Regex(currentFilter, RegexOptions.IgnoreCase | RegexOptions.Compiled, TimeSpan.FromSeconds(1)); } } return (filterRegex != null); }