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)
还没有任何评论哟~
