Sprongboot啟動activeMq(點對點模式) [復制鏈接]

2019-12-6 16:51
Gendan5 閱讀:234 評論:0 贊:0
Tag:  
Sprongboot啟動activeMq(點對點模式)
先引入activeMq的依賴
<!--activemq依賴-->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-activemq</artifactId>
    </dependency>
    <dependency>
        <groupId>javax.jms</groupId>
        <artifactId>javax.jms-api</artifactId>
        <version>2.0.1</version>
    </dependency>
    <!-- ******************** -->
<!--activemq依賴-->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-activemq</artifactId>
    </dependency>
    <dependency>
        <groupId>javax.jms</groupId>
        <artifactId>javax.jms-api</artifactId>
        <version>2.0.1</version>
    </dependency>
    <!-- ******************** -->
在web的啟動類中配置隊列信息
public class UserApplication {
public static void main(String[] args) {
SpringApplication.run(UserApplication.class,args);
}
@Bean //注入beanMT5使用教程www.gendan5.com/mt5.html點對點模式
public Queue queue(){
return new ActiveMQQueue(“queue”);
}

 //注入bean 訂閱模式
1
@Bean
public ActiveMQTopic activeMQTopic(){
return new ActiveMQTopic(“topic”);
}
}

引入注解 在控制層中發送消息給隊列
@Autowired
private JmsTemplate jms;
@Autowired
private Queue queue;

/**
 * 將注冊信息存入mq
 * @param user
 */
@PostMapping("/addQueue")
public void addUser(@RequestBody final User user){
//jms發送消息的方法
    jms.send(queue, new MessageCreator() {
        @Override
        public Message createMessage(Session session) throws JMSException {
            String s = JSONObject.toJSONString(user);
            return session.createTextMessage(s);
        }
    });
}
/**
 * 將注冊信息存入mq
 * @param user
 */
@PostMapping("/addQueue")
public void addUser(@RequestBody final User user){
//jms發送消息的方法
    jms.send(queue, new MessageCreator() {
        @Override
        public Message createMessage(Session session) throws JMSException {
            String s = JSONObject.toJSONString(user);
            return session.createTextMessage(s);
        }
    });
}
————————————————
在另一個微服務可通過監聽隊列接受mq中的消息
配置application.yml

最后啟動項目和mq就可以測試了


我來說兩句
您需要登錄后才可以評論 登錄 | 立即注冊
facelist
所有評論(0)
領先的中文移動開發者社區
18620764416
7*24全天服務
意見反饋:[email protected]

掃一掃關注我們

Powered by Discuz! X3.2© 2001-2019 Comsenz Inc.( 粵ICP備15117877號 )

时时彩改欢乐生肖 查今天上海11选5开奖号 上海时时乐历史开奖 上海11选5免费计划网站 北京赛车pk拾 江西11选5奖金规则 牛达人配资 股票怎么玩 甘肃快三和值走势图一定 基本面分析的主要内容 2019管家婆最准的资料 贵州快3选号 大乐透玩法介绍 股票的涨跌怎么看 重庆快乐十分怎么赚钱 世界股票指数 pc蛋蛋赌博喊话