转载

springboot~rabbitmq自己通过UI手动发布队列需要注意的地方

springboot里发布队列消息

为了兼容性和可读性更好，我们一般使用json字符串做为数据载体。

public void decreaseCallMonitor(CallMonitorInfo callMonitorInfo) throws Exception {
    try {
      rabbitTemplate.convertAndSend(
          AmqpConfig.DATA_COLLECTION_EXCHANGE,
          AmqpConfig.CALLMONITOR_DECREASE_BINDING,
          objectMapper.writeValueAsString(callMonitorInfo)
      );
      logger.debug("Enter {},message:{}", "decreaseCallMonitor", callMonitorInfo.toString());

    } catch (Exception ex) {
      logger.error("MQ.decreaseCallMonitor.error", ex);
    }
  }

springboot里订阅消息

@RabbitHandler
  @RabbitListener(queues = AmqpConfig.CUSTOMER_TERMINATE_BINDING)
  public void customerTerminate(String data) {
    try {
      TerminateDTO terminateDTO = objectMapper.readValue(data, TerminateDTO.class);
      customerBusinessInfoMapper.updateCustomer_business_info(ImmutableMap.of(
          "status", EnumCustomerStatus.TERMINATE.getCode(),
          "customerId", terminateDTO.getCustomerId()
      ));
    } catch (Exception ex) {
      logger.error("解约同步异常", ex);
    }
  }

通过UI15672手动发消息要注意的地方

添加properties，声明它是utf-8及文本类型

content_encoding:utf-8
content_type:text/plain

json字符串需要压缩，把回车换行都去掉，否则会出错

{"signSalespersonId":1001,"signSalesperson":"mq","signTime":null,"customerId":501806811767111700}

以上两点注意好，手动发布队列就没有问题了！

原文 http://www.cnblogs.com/lori/p/9805575.html

正文到此结束

所属分类： Spring

本文标签： cat value Collection js json IO HTML mapper amqp mina App queue bus tab NSA message bug update 数据 http springboot spring UI 同步 id rmi map list MQ
版权声明： 本文为互联网转载文章，出处已在文章中说明(部分除外)。如果侵权，请联系本站长删除，谢谢。
本文海报： 生成海报一生成海报二

其他链接

关于本站

本站定位：个人技术类博客

本站作用：写博客、记日志、闲聊扯淡鼓捣技术。

问题交流

springboot~rabbitmq自己通过UI手动发布队列需要注意的地方

springboot里发布队列消息

springboot里订阅消息

通过UI15672手动发消息要注意的地方

热门推荐

相关文章

说给你听

本文目录

随机标签

书籍教程

近期评论

网站信息

其他链接

关于本站

问题交流