rocket mq发送消息指定broket

在RocketMQ中，发送消息时可以指定消息发送到哪个Broker节点。可以通过设置MessageQueueSelector来实现。

以下是一个示例代码：

import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.client.producer.MessageQueueSelector;
import org.apache.rocketmq.common.message.Message;
import org.apache.rocketmq.common.message.MessageQueue;
import org.apache.rocketmq.remoting.common.RemotingHelper;

import java.util.List;

public class MyProducer {

    private static final String NAMESRV_ADDR = "localhost:9876";
    private static final String TOPIC_NAME = "my-topic";
    private static final String TAG_NAME = "my-tag";

    public static void main(String[] args) throws Exception {
        DefaultMQProducer producer = new DefaultMQProducer("my-group");
        producer.setNamesrvAddr(NAMESRV_ADDR);
        producer.start();

        for (int i = 0; i < 100; i++) {
            Message message = new Message(TOPIC_NAME, TAG_NAME, ("Hello RocketMQ " + i).getBytes(RemotingHelper.DEFAULT_CHARSET));
            producer.send(message, new MyMessageQueueSelector(), i);
        }

        producer.shutdown();
    }

    private static class MyMessageQueueSelector implements MessageQueueSelector {

        @Override
        public MessageQueue select(List<MessageQueue> list, Message message, Object o) {
            int id = (int) o;
            int index = id % list.size();
            return list.get(index);
        }
    }
}

在MyProducer中，我们通过DefaultMQProducer来发送消息。在发送消息时，通过设置MessageQueueSelector来指定发送到哪个Broker节点。

MyMessageQueueSelector中的select方法返回消息队列的下标，根据下标来选择发送到哪个Broker节点。

需要注意的是，如果要实现发送到指定的Broker节点，需要先了解RocketMQ的Broker节点分配策略，确保选择的Broker节点是符合要求的。