内容简介:为了兼容性和可读性更好,我们一般使用json字符串做为数据载体。以上两点注意好,手动发布队列就没有问题了!
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}
以上两点注意好,手动发布队列就没有问题了!
以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,也希望大家多多支持 码农网
猜你喜欢:本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。
Java编程思想 (第4版)
[美] Bruce Eckel / 陈昊鹏 / 机械工业出版社 / 2007-6 / 108.00元
本书赢得了全球程序员的广泛赞誉,即使是最晦涩的概念,在Bruce Eckel的文字亲和力和小而直接的编程示例面前也会化解于无形。从Java的基础语法到最高级特性(深入的面向对象概念、多线程、自动项目构建、单元测试和调试等),本书都能逐步指导你轻松掌握。 从本书获得的各项大奖以及来自世界各地的读者评论中,不难看出这是一本经典之作。本书的作者拥有多年教学经验,对C、C++以及Java语言都有独到......一起来看看 《Java编程思想 (第4版)》 这本书的介绍吧!