av一区二区在线观看_亚洲男人的天堂网站_日韩亚洲视频_在线成人免费_欧美日韩精品免费观看视频_久草视

您的位置:首頁技術文章
文章詳情頁

使用spring stream發送消息代碼實例

瀏覽:117日期:2023-09-06 16:04:57

為什么使用spring stream ?

spring stream 是用來做消息隊列發送消息使用的。他隔離了各種消息隊列的區別,使用統一的編程模型來發送消息。

目前支持:

rabbitmq kafka rocketmq

啟動rocketmq

rocketmq 支持windows

start mqnamesrv.cmdstart mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true

修改pom.xml

<dependency> <groupId>com.alibaba.cloud</groupId> <artifactId>spring-cloud-stream-binder-rocketmq</artifactId> </dependency>

增加發送接收JAVA代碼

public interface InputOutput { String MAIL_OUTPUT = 'mailOutput'; String MAIL_INPUT = 'mailInput'; String OUTPUT = 'output'; String INPUT = 'input'; @Output(OUTPUT) MessageChannel output(); @Input(INPUT) SubscribableChannel input(); @Output(MAIL_OUTPUT) MessageChannel mailOutput(); @Input(MAIL_INPUT) SubscribableChannel mailInput();}

在應用上增加注解

@EnableBinding({InputOutput.class})

增加yml配置

spring: cloud: stream: rocketmq: binder: name-server: 127.0.0.1:9876 bindings: output: destination: bpmmessage group: bpmmessage-groupinput: destination: bpmmessage group: bpmmessage-group-consumermailOutput: destination: mail group: mail-groupmailInput:destination: mailgroup: mail-group-consumer

編寫代碼收發消息:

MessageModel messageModel=new MessageModel(); messageModel.setMsgType('mail'); messageModel.setContent('helloworld'); inputOutput.mailOutput().send( MessageBuilder.withPayload('mail' ).build()); inputOutput.output().send(MessageBuilder.withPayload( messageModel).build() );

這里發送的是兩類消息。

接收消息:

@Servicepublic class MessageListener { @StreamListener(InputOutput.INPUT) public void receive(MessageModel message) { System.err.println(message); System.err.println('ok'); } @StreamListener(InputOutput.MAIL_INPUT) public void receive(String message) { System.err.println(message); System.err.println('ok'); }}

分別接收兩類消息

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持好吧啦網。

標簽: Spring
相關文章:
主站蜘蛛池模板: 国产精品一区二区三区在线 | 国产精品一区二区三区在线 | 国产一区二区三区四区在线观看 | 亚洲自拍偷拍免费视频 | 亚洲精彩视频在线观看 | 免费黄色在线观看 | 91精品久久久 | 一二三区在线 | 一区二区三区在线播放视频 | 亚洲欧美视频一区二区 | 欧美精品一区二区三区一线天视频 | 中文字幕中文字幕 | 91国内精精品久久久久久婷婷 | 国产成人麻豆免费观看 | 欧美日韩国产不卡 | 91国产精品在线 | 欧美成人免费在线视频 | 久久88| 一级毛片在线播放 | 国产一区二区不卡 | 欧美在线观看一区二区 | 中文字幕亚洲精品 | 天天操天天干天天曰 | 亚洲视频 欧美视频 | a级在线免费观看 | 欧美成人一区二免费视频软件 | 欧美精品一区二区三区视频 | 91精品国产综合久久久久 | 一级黄色片一级黄色片 | 一区二区免费在线观看 | 欧美一级片a | 黑人巨大精品欧美黑白配亚洲 | 日韩一三区 | 久久鲁视频 | 91在线一区 | 福利av在线| 91九色网站 | 国产 欧美 日韩 一区 | 国产日韩一区二区三免费高清 | 亚洲精品久久久久久一区二区 | 成人av在线网站 |