Sprongboot启动activeMq(点对点模式) [复制链接]

2019-12-6 16:51
Gendan5 阅读:311 评论: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全天服务
意见反馈:1294855032@qq.com

扫一扫关注我们

Powered by Discuz! X3.2© 2001-2019 Comsenz Inc.( 粤ICP备15117877号 )