Advertisement

RabbitMq消费信息对数据处理及编码设置

阅读量:

RabbitMq消费信息,对数据处理和编码设置

若未对消息内容实施相应处理,单纯将信息存入MQ队列则难以体现其实际价值与应用意义。

普通消费

若仅需处理消费消息,只需编写一个实现类,并完成对MessageListener接口中onMessage方法的具体实现即可,如

复制代码
    public class RabbitmqService implements MessageListener {
    
    private Logger logger = LoggerFactory.getLogger(RabbitmqService.class);
    
    @Autowired
    private UserService userService;
    
    @Autowired
    private MsgInfoService msgInfoService;
    
    public void onMessage(Message message) {
      
        try {
        	//将放入队列的消息已UTF-8的格式转为JSON字符串(前提是放入队列是也是JSON字符串,中文存在乱码)
            String  msg  = new String(mess

全部评论 (0)

还没有任何评论哟~