基于AMQPNetLite.Core使用ActiveMQ Artemis消息分组与排他队列遇阻

一、排他队列设置错误修正 #

你当前把Exclusive属性设置在连接的Open帧属性中，这是错误的。AMQP协议中，排他队列的属性需要在队列声明（或ReceiverLink的Source配置）中指定，而非连接层面。

修改代码如下，通过配置ReceiverLink的Source来创建排他队列：

static async Task Main(string[] args)
{
    string url = (args.Length > 0) ? args[0] :
        "amqp://admin:passw0rd@127.0.0.1:5672";
    string source = (args.Length > 1) ? args[1] : "examples";
    int count = (args.Length > 2) ? Convert.ToInt32(args[2]) : 10;

    ConnectionFactory factory = new ConnectionFactory();
    Address peerAddr = new Address(url);
    // 连接属性无需设置Exclusive
    Connection connection = await factory.CreateAsync(peerAddr, new Open { ContainerId = Guid.NewGuid().ToString() });
    Session session = new Session(connection);

    // 构建Source对象，配置排他队列属性
    var queueSource = new Source
    {
        Address = source,
        // 开启动态队列创建（如果队列不存在，让Artemis自动创建）
        Dynamic = true,
        // 设置队列排他属性
        Exclusive = true,
        // 补充Artemis识别排他状态的节点属性
        DynamicNodeProperties = new Amqp.Types.Fields
        {
            { new Symbol("exclusive"), true }
        }
    };

    ReceiverLink receiver = new ReceiverLink(session, "recv-1", queueSource);

    while (true)
    {
        Message msg = receiver.Receive();
        receiver.Accept(msg);
        Console.WriteLine("Received: " + msg.Body.ToString());
    }
}

关键说明：

• Dynamic = true：让ActiveMQ Artemis自动创建目标队列（若队列不存在）
• Exclusive = true：标记队列为排他状态，仅当前ReceiverLink所属连接可访问
• DynamicNodeProperties：补充Artemis需要的节点属性，确保控制台能正确识别排他配置

如果使用预先创建的队列，需先在Artemis控制台或配置文件中将队列设置为排他，再通过ReceiverLink连接。

二、消息分组实现方法 #

ActiveMQ Artemis的消息分组在AMQP协议下，通过消息的group-id属性或ReceiverLink的过滤规则实现：

1. 发送消息时指定分组ID #

发送消息时设置Message.GroupId，同组ID的消息会被路由到同一个消费者：

SenderLink sender = new SenderLink(session, "send-1", source);
for (int i = 0; i < count; i++)
{
    Message msg = new Message($"Message {i}");
    // 按业务标识设置分组ID，比如用户ID、订单批次等
    msg.GroupId = "group-001";
    await sender.SendAsync(msg);
}

2. 消费者绑定特定分组（可选） #

若需消费者仅接收指定分组的消息，可在ReceiverLink的Source中设置过滤规则：

var queueSource = new Source
{
    Address = source,
    Filter = new FilterSet
    {
        { new Symbol("group-id"), "group-001" }
    }
};
ReceiverLink receiver = new ReceiverLink(session, "recv-group-001", queueSource);

验证排他队列 #

修改代码后重新运行，在ActiveMQ Artemis控制台的队列列表中，目标队列的Exclusive属性会显示为true，且其他连接无法创建该队列的ReceiverLink。

内容的提问来源于stack exchange，提问作者shyamasundara