首页 > 极客资料 博客日记
使用MessagePipe实现进程间通信
2024-09-28 14:30:05极客资料围观17次
文章使用MessagePipe实现进程间通信分享给大家,欢迎收藏极客之家,专注分享技术知识
1、MessagePipe介绍
可以用于.NET
和Unity
上面的高性能的内存/分布式消息传递管道。适用于发布/订阅模式、CQRS的中介模式、Prism中的EventAggregator、IPC(进程间通信)-RPC等。
支持:
- 依赖注入
- 过滤器管道
- 更好的事件
- 同步/异步
- 带键值的/无键值的
- 单例/Scoped
- 广播/响应(+更多)
- 内存/进程间/分布式
MessagePipe
比标准的 C# event更快,是Prism的EventAggregator的78倍。下面是官方给出的测试截图
每次使用publish
分配的内存更少
还提供了Roslyn分析器以防止订阅泄露。
本库采用MIT
协议
2、MessagePipe分布式发布/订阅的使用(进程间通信)
2.1 新建两个Wpf项目
项目名称分别为:MessagePipePublishApp
和MessagePipeSubscribeApp
,Publish项目用于发布消息,Subscribe项目用于接收消息。项目采用Prism框架进行搭建。通过重载的CreateContainerExtension
方法中进行依赖注入。
两个项目对MessagePipe
功能注入代码如下:
Publish项目代码:
var services = new ServiceCollection();
services
.AddMessagePipe()
.AddUdpInterprocess(
"127.0.0.1",
3215,
options =>
{
options.InstanceLifetime = InstanceLifetime.Singleton;
}
);
Subscribe项目代码:
var services = new ServiceCollection();
services
.AddMessagePipe()
.AddUdpInterprocess(
"127.0.0.1",
3215,
options =>
{
options.InstanceLifetime = InstanceLifetime.Singleton;
}
);
2.2 实现代码
两个项目通过构造函数注入方式注入IDistributedPublisher
接口。
Publish项目,通过一个按钮的命令实现发送消息的功能:实现代码如下:
[RelayCommand]
private async Task PublishAsync()
{
await _distributedPublisher.PublishAsync(
"abc",
$"Message:{DateTime.Now:yyyy-MM-dd HH:mm:ss.fff}"
);
}
按钮点击一次,发送一次消息。
Subscribe项目中在窗口的Loaded方法中进行实现对订阅消息的接收,并将消息添加到列表中进行展示。
[RelayCommand]
private async Task LoadedAsync()
{
await _distributedSubscriber.SubscribeAsync(
"abc",
message =>
{
Application.Current.Dispatcher.InvokeAsync(() =>
{
Messages.Add(message);
});
}
);
}
2.3 运行效果
版权声明:本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:jacktools123@163.com进行投诉反馈,一经查实,立即删除!
标签:
相关文章
最新发布
- Nuxt.js 应用中的 prerender:routes 事件钩子详解
- 【问题解决】Tomcat由低于8版本升级到高版本使用Tomcat自带连接池报错无法找到表空间的问题
- 【FAQ】HarmonyOS SDK 闭源开放能力 —Vision Kit
- 六、Spring Boot集成Spring Security之前后分离认证流程最佳方案
- 《JVM第7课》堆区
- .NET 8 高性能跨平台图像处理库 ImageSharp
- 还在为慢速数据传输苦恼?Linux 零拷贝技术来帮你!
- 刚毕业,去做边缘业务,还有救吗?
- 如何避免 HttpClient 丢失请求头:通过 HttpRequestMessage 解决并优化
- 让性能提升56%的Vue3.5响应式重构之“版本计数”