Shulou(Shulou.com)06/02 Report--

In this issue, Xiaobian will bring you about how to deal with various message types in RabbitMQ. The article is rich in content and analyzes and narrates from a professional perspective. After reading this article, I hope you can gain something.

Map message

If the message type sent is map type, you can convert the message to map type using the SerializationUtils.deserialize method.

String type (including json format)

By default RabbitMQ sends messages in bytecode. Sometimes we need to send messages in JSON format, so there are two ways to handle them.

manually convert to json@Autowiredprivate ObjectMapper objectMapper;

public void sendOrder(Order order) { try { String orderJson = objectMapper.writeValueAsString(order); Message message = MessageBuilder .withBody(orderJson.getBytes()) .setContentType(MessageProperties.CONTENT_TYPE_JSON) .build(); this.rabbitTemplate.convertAndSend(RabbitConfig.QUEUE_ORDERS, message); } catch (JsonProcessingException e) { e.printStackTrace(); }}

But it would be tedious to write this way everywhere you send a message.

Automatic conversion to json using MessageConvert

If you specify the message format as JSON and use a message converter, the message will be automatically converted to json format without having to manually convert each time. RabbitTemplate uses SimpleMessageConverter as its message converter by default, and SimpleMessageConverter does not meet the needs of json messages. We can use Jackson2JsonMessageConverter as the default message converter.

Configure MessageConverter for RabbitTemplate:

@Configurationpublic class RabbitConfig {

@Bean public RabbitTemplate rabbitTemplate(final ConnectionFactory connectionFactory) { final RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory); rabbitTemplate.setMessageConverter(jsonMessageConverter()); return rabbitTemplate; }

@Bean public Jackson2JsonMessageConverter jsonMessageConverter() { return new Jackson2JsonMessageConverter(); }}

String class constructor receives byte[] type message data, jsonStr can be converted to other classes, and then related operations.

Here the @RabbitListener annotation is on the method, if there are multiple methods annotated @RabbitListener(queues = TopicRabbitmqConfig.EVENT_MSG_QUEUE_NAME) in the class, the result of the test is a rotating call.

Another way to receive.

Note that here the RabbitListener annotation is on the class and the method is identified by the @RabbitHandler annotation.

pick

Spring boot and rabbitmq

Sanfeng, public number: soft Zhang Sanfeng spring boot and RabbitMQ console

Open the RabbitMQ web console and you can also see the switches and queues we configured in the code just now, as well as the binding information.

View details of the exchanger

view the queue

The above is how to deal with various message types in RabbitMQ shared by Xiaobian. If there is a similar doubt, please refer to the above analysis for understanding. If you want to know more about it, please pay attention to the industry information channel.

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.