第七色在线视频,2021少妇久久久久久久久久,亚洲欧洲精品成人久久av18,亚洲国产精品特色大片观看完整版,孙宇晨将参加特朗普的晚宴

為了賬號(hào)安全,請(qǐng)及時(shí)綁定郵箱和手機(jī)立即綁定
已解決430363個(gè)問(wèn)題,去搜搜看,總會(huì)有你想問(wèn)的

獲取rabbitmq消息的正文部分

獲取rabbitmq消息的正文部分

我已經(jīng)為 rabbit mq 設(shè)置了一個(gè)簡(jiǎn)單的監(jiān)聽器@RabbitListener(queues = SECOND_QUEUE)    public void onMessage(Message message) {     LOGGER.info("second queue listener.........");     LOGGER.info(message.toString());    }這給出了這種格式的消息 (Body:'1460' MessageProperties [headers={}, timestamp=null, messageId=null, userId=null, receivedUserId=null, appId=null, clusterId=null, type=null, correlationId=null, correlationIdString=null, replyTo=null, contentType=application/x-java-serialized-object, contentEncoding=null, contentLength=0, deliveryMode=null, receivedDeliveryMode=PERSISTENT, expiration=null, priority=0, redelivered=false, receivedExchange=, receivedRoutingKey=bottomlesspit, receivedDelay=null, deliveryTag=1, messageCount=0, consumerTag=amq.ctag-PpEjG_BokAg-A4wllCgeqA, consumerQueue=bottomlesspit])在控制臺(tái)上。我也有興趣在客戶端處理消息,我有這個(gè)var onConnect = function() {   client.subscribe("/topic/messages", function(d) {   var str = d.body   var res = str.match(/Body:\'(.+)\'/);   console.log("I control this",res[1]);   }); };我只想在 java 中獲取主體,因?yàn)樗俏夷壳拔ㄒ桓信d趣的部分。是否有一個(gè)功能已經(jīng)在 java 和 stomp 中實(shí)現(xiàn),僅用于獲取正文部分?。
查看完整描述

3 回答

?
明月笑刀無(wú)情

TA貢獻(xiàn)1828條經(jīng)驗(yàn) 獲得超4個(gè)贊

message.getBody()是您所需要的 - 它將返回byte[],您需要在知道您正在使用的消息格式的情況下對(duì)其進(jìn)行轉(zhuǎn)換:


@RabbitListener(queues = SECOND_QUEUE)

public void onMessage(Message message) {

    byte[] body = message.getBody();

    // do what you need with the body

}


查看完整回答
反對(duì) 回復(fù) 2021-12-22
?
千巷貓影

TA貢獻(xiàn)1829條經(jīng)驗(yàn) 獲得超7個(gè)贊

您可以像這樣獲取數(shù)據(jù):


@Override

    public void onMessage(Message message, byte[] pattern) {

        yourmap.put("data", message);

        send();

    }

然后,


String s = yourmap.get("data").toString();

您可以從流中獲取已發(fā)布的數(shù)據(jù)。


我希望這將有所幫助。


查看完整回答
反對(duì) 回復(fù) 2021-12-22
?
BIG陽(yáng)

TA貢獻(xiàn)1859條經(jīng)驗(yàn) 獲得超6個(gè)贊

這對(duì)我有用


@RabbitListener(queues = SECOND_QUEUE)

public void onMessage(Message message) {

 LOGGER.info("second queue listener.........");

 //LOGGER.info(message.toString());

 byte[] body = message.getBody();

LOGGER.info("This was the output from the listener "+new String(body));

}


查看完整回答
反對(duì) 回復(fù) 2021-12-22
  • 3 回答
  • 0 關(guān)注
  • 334 瀏覽
慕課專欄
更多

添加回答

舉報(bào)

0/150
提交
取消
微信客服

購(gòu)課補(bǔ)貼
聯(lián)系客服咨詢優(yōu)惠詳情

幫助反饋 APP下載

慕課網(wǎng)APP
您的移動(dòng)學(xué)習(xí)伙伴

公眾號(hào)

掃描二維碼
關(guān)注慕課網(wǎng)微信公眾號(hào)