第詳解SpringBoot中使用RabbitMQ的RPC功能MessagePropertiesmp=newMessageProperties();

byte[]src=s.getBytes(Charset.forName("UTF-8"));

//mp.setReplyTo("adsdas");加載AmqpTemplate時(shí)設(shè)置，這里設(shè)置沒用

//mp.setCorrelationId("2222");系統(tǒng)生成，這里設(shè)置沒用

mp.setContentType("application/json");

mp.setContentEncoding("UTF-8");

mp.setContentLength((long)s.length());

returnnewMessage(src,mp);

3.寫消費(fèi)者

packagecom.ws.listener.mq;

importjava.nio.charset.Charset;

importorg.springframework.amqp.core.Message;

importorg.springframework.amqp.core.MessageProperties;

importorg.springframework.amqp.rabbit.annotation.RabbitListener;

importorg.springframework.amqp.rabbit.core.RabbitTemplate;

importorg.springframework.beans.factory.annotation.Autowired;

importorg.springframework.stereotype.Component;

importmon.RabbitMQConfig;

importlombok.extern.slf4j.Slf4j;

@Slf4j

@Component

publicclassReceiver{

@Autowired

privateRabbitTemplaterabbitTemplate;

@RabbitListener(queues=RabbitMQConfig.TOPIC_QUEUE1)

publicvoidreceiveTopic1(Messagemsg){

("隊(duì)列1:"+msg.toString());

StringmsgBody=newString(msg.getBody());

//數(shù)據(jù)處理，返回的Message

MessagerepMsg=con(msgBody+"返回了",msg.getMessageProperties().getCorrelationId());

rabbitTemplate.send(RabbitMQConfig.TOPIC_EXCHANGE,RabbitMQConfig.TOPIC_QUEUE2,repMsg);

@RabbitListener(queues=RabbitMQConfig.TOPIC_QUEUE2)

publicvoidreceiveTopic2(Messagemsg){

("隊(duì)列2:"+msg.toString());

publicMessagecon(Strings,Stringid){

MessagePropertiesmp=newMessageProperties();

byte[]src=s.getBytes(Charset.forName("UTF-8"));

mp.setContentType("application/json");

mp.setContentEncoding("UTF-8");

mp.setCorrelationId(id);

returnnewMessage(src,mp);

日志打?。?/p>

2025-06-2617:11:16.607[http-nio-8080-exec-4]INFOcom.ws.controller.UserController-客戶端--------------------(Body:‘報(bào)文的內(nèi)容'MessageProperties[headers={},contentType=application/json,contentEncoding=UTF-8,contentLength=5,deliveryMode=PERSISTENT,priority=0,deliveryTag=0])

2025-06-2617:11:16.618[SimpleAsyncTaskExecutor-1]INFOcom.ws.listener.mq.Receiver-隊(duì)列1:(Body:‘報(bào)文的內(nèi)容'MessageProperties[headers={},correlationId=1,replyTo=topic.queue2,contentType=application/json,contentEncoding=UTF-8,contentLength=0,receivedDeliveryMode=PERSISTENT,priority=0,redelivered=false,receivedExchange=topic.exchange,receivedRoutingKey=topic.queue1,deliveryTag=1,consumerTag=amq.ctag-8IzlhblYmTebqUYd-uferw,consumerQueue=topic.queue1])

2025-06-2617:11:16.623[http-nio-8080-exec-4]INFOcom.ws.controller.UserController-回應(yīng)：報(bào)文的內(nèi)容返回了