简介

消息队列：ActiveMQ

Class	说明
Consumer<T> Producer<T>	核心类
SimpleConsumer SimpleProducer	只支持基础功能

• Consumer<T>:

// 消费消息异常时，支持重新消费
args.ShouldRecovery = true;

• Producer<T>:

// 发送消息异常时，支持本地持久化存储消息并定时重发
options.PersistMsgWhenException = true;

Packages

Package	NuGet Stable	NuGet Pre-release	Downloads
Sean.Core.MQ.ActiveMQ

Nuget包引用

• Package Manager

PM> Install-Package Sean.Core.MQ.ActiveMQ

默认端口

ActiveMQ

协议	默认端口	备注
http	8161	登陆：admin\admin
tcp	61616	failover：故障转移配置，自动尝试重连

配置示例

配置文件：

• .NET Core：appsettings.json

{
  "ActiveMQ": {
    "BrokerUri": "failover:tcp://127.0.0.1:61616/"
  }
}

• .NET Framework：app.config、web.config

  <appSettings>
    <add key="ActiveMQBrokerUri" value="failover:tcp://127.0.0.1:61616/" />
  </appSettings>

使用示例

项目：test\Demo.NetCore