当前位置：首页 > 软件库 > 服务器软件 > JMS/消息中间件 >

EasyNetQ

RabbitMQ 的 .NET 开发包

授权协议 MIT

开发语言 C# .NET

所属分类服务器软件、 JMS/消息中间件

软件类型开源软件

地区不详

投递者阎祖鹤

操作系统 Windows

开源组织无

适用人群未知

软件概览

EasyNetQ 是 RabbitMQ 的 .NET 开发包。

示例代码：

var bus = RabbitHutch.CreateRabbitBus("localhost");
var message = new MyMessage {Text = "Hello!"};
bus.Publish(message);

目标：

尽可能简化在.NET上使用RabbitMQ的工作。

要连接到RabbitMQ代理...

var bus = RabbitHutch.CreateBus("host=localhost");

要发布消息...

bus.Publish(message);

订阅消息...

bus.Subscribe<MyMessage>("my_subscription_id", msg => Console.WriteLine(msg.Text));

远程过程调用...

var request = new TestRequestMessage {Text = "Hello from the client! "};
bus.Request<TestRequestMessage, TestResponseMessage>(request, response => 
    Console.WriteLine("Got response: '{0}'", response.Text));

RPC服务器...

bus.Respond<TestRequestMessage, TestResponseMessage>(request => 
	new TestResponseMessage{ Text = request.Text + " all done!" });

使用案例

EasyNetQ使用(三)【Publish与Subcribe】

EasyNetQ支持的最简单的消息模式是发布/订阅.这个模式是一个极好的方法用来解耦消息提供者和消费者。消息发布者只要简单的对世界说，“这里有些事发生” 或者 “我现在有一个信息”。它不关心有没有人监听，或者接收者是谁，或者接收者在那里。我们能够添加和移除特定类型的消息的订阅者，不需发布者做任何的重新配置。我们也能够有多个发布者发布相同的消息，添加和删除发布者也不用其他的发布者或者订阅者做任何重新
EasyNetQ使用(一)【介绍】

EasyNetQ 是一个容易使用，专门针对RabbitMQ的 .NET API。假如你尽可能快的想去安装和运行RabbitMQ，请去看入门指南。 EasyNetQ是为了提供一个尽可能简洁的适用与RabbitMQ的.NET类库。为了实现这些目标，EasyNetQ提供一种自认为你会在.NET下使用RabbitMQ的视图。为了保持使用灵活性，简单起见，EasyNetQ强制使用了一些简单的约定。包括如下
EasyNetQ 连接 RabbitMQ

如果您习惯于处理与 SQL Server 等关系数据库的连接，那么您可能会发现 EasyNetQ 处理连接的方式有点奇怪。与关系数据库的通信始终由客户端启动。客户端打开连接，发出 SQL 命令，在必要时处理结果，然后关闭连接。一般的建议是，您应该在尽可能短的时间内保持打开连接，并将连接池保留给API。与 RabbitMQ 等消息代理进行交谈有点不同，因为连接往往会持续应用程序的生命周期。通常，您
【EasyNetQ】- 自动订阅者

从v0.7.1.30开始，EasyNetQ简单易用AutoSubscriber。你可以用它来轻松地扫描实现任何接口的类的特定组件IConsume<T>或IConsumeAsync<T>，然后让汽车用户订阅这些消费者到你的总线。一个实现IConsume<T>将使用总线订阅方法，而实现IConsumeAsync<T>将使用总线SubscribeAsync方法，请参阅订阅详细信息。您当然可以让您的消费者
【EasyNetQ】- 订阅

EasyNetQ订阅者订阅消息类型（消息类的.NET类型）。一旦通过调用Subscribe方法设置了对类型的订阅，就会在RabbitMQ代理上创建一个持久队列，并且该类型的任何消息都将被放置在队列中。只要连接，RabbitMQ就会将任何消息从队列发送给用户。要订阅消息，我们需要为EasyNetQ提供在消息到达时执行的操作。我们通过传递订阅委托来做到这一点： bus.Subscribe<MyMes
EasyNetQ自定义异常消息处理

EasyNetQ自定义异常消息处理参考文章：（1）EasyNetQ自定义异常消息处理（2）https://www.cnblogs.com/chinaboard/p/3579756.html 备忘一下。

EasyNetQ

同类工具

相关阅读

相关文章

相关问答

相关文档