生产者MessageQueueSelector实战

2020-04-03 11:00:49 阅读：290 来源： 互联网

标签：实战生产者 message list send 发送 produce Message MessageQueueSelector

top下面默认有四个Queue, queque的数量不能大约配置,否者会报错

假设一个top下面有三个类目,分别是手机,衣服,食品,他们发送消息都是随机发送到一个queue里面,如果有一天,衣服的消息突然增多了,堵塞队列了,其他两个类目也会受到影响,造成消息发送失败,这个的话就可以指定类目发送到哪个queue,手机指定发送到队列0 ,衣服发送队列1,这样即使衣服的消息增多了也不会影响其他队列,但这样也会失去负载均衡

代码案例:

同步发送

@Override
public MtopResult api(MtopInnerRequest request) throws InterruptedException, RemotingException, MQClientException, MQBrokerException {
    List<Produce> list = Produce.produceList();

    //MessageQueueSelector 选择
    if (! CollectionUtils.isEmpty(list)){
        for (Produce produce : list) {
            Message message = new Message("box","orderMessage",produce.getId(),JSON.toJSONString(produce).getBytes());

            SendResult send = payProduct.getProducer().send(message, new MessageQueueSelector() {
                @Override
                public MessageQueue select(List<MessageQueue> list, Message message, Object o) {
                    Integer queusNum = Integer.valueOf(o.toString());
                    return list.get(queusNum);
                }
            }, 0);
     System.out.printf("发送结果=%s, msg=%s ", send.getSendStatus(), send.toString());
        }
    }

top 默认是4个queue

queue不能大于配置,

报错

异步发送

//MessageQueueSelector 选择
if (!CollectionUtils.isEmpty(list)) {

    for (Produce produce : list) {
        Message message = new Message("box", "orderMessage", produce.getId(), JSON.toJSONString(produce).getBytes());
        payProduct.getProducer().send(message, (list1, message1, o) ->
                {
                    Integer integer = Integer.valueOf(o.toString());
                    return list1.get(integer);
                }
                , 4, new SendCallback() {

                    @Override
                    public void onSuccess(SendResult sendResult) {
                        System.out.printf("发送结果=%s, msg=%s ", sendResult.getSendStatus(), sendResult.toString());

                    }

                    @Override
                    public void onException(Throwable throwable) {
                        System.out.println(throwable);
                        throwable.printStackTrace();
                    }
                });
    }

标签：实战,生产者,message,list,send,发送,produce,Message,MessageQueueSelector
来源： https://www.cnblogs.com/HuangXingLei/p/12620242.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

生产者MessageQueueSelector实战