ASP源码.NET源码PHP源码JSP源码JAVA源码DELPHI源码PB源码VC源码VB源码Android源码
当前位置:首页 >> 网络编程 >> 其他编程教程 >> spring boot + ActiveMQ 实现消息服务

spring boot + ActiveMQ 实现消息服务(1/2)

来源:网络整理     时间:2016-03-20     关键词:

本篇文章主要介绍了"spring boot + ActiveMQ 实现消息服务",主要涉及到方面的内容,对于其他编程教程感兴趣的同学可以参考一下: 上篇博客带来的是spring boot + redis实现session共享的文章,这次给大家带来的是spring boot + activemq。首先,我在g...

上篇博客带来的是spring boot + redis实现session共享的文章,这次给大家带来的是spring boot + activemq。

首先,我在github上找到了一个不错的demo,这里放给大家一起看下:

https://github.com/spring-projects/spring-boot/tree/master/spring-boot-samples/spring-boot-sample-activemq

确实可以实现功能,但是当我在8161默认的admin端口进行queue查询时,发现并没有我们的github-queue,虽然不太清楚具体的原因,但是解决方式倒是找到了,下面贴一下自己的实现:

pox.xml:

<!-- ActiveMQ -->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jms</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.activemq</groupId>
            <artifactId>activemq-all</artifactId>
            <version>5.13.2</version>
        </dependency>

application.properties:

spring.activemq.in-memory=true
spring.activemq.pooled=false

接下来就是jms的配置了,首先是ActiveMQ4Config文件:

@EnableJms
@Configuration
public class ActiveMQ4Config {

    @Bean
    public Queue queue() {
        return new ActiveMQQueue("github-queue");
    }

    @Bean
    public ActiveMQConnectionFactory activeMQConnectionFactory (){
        ActiveMQConnectionFactory activeMQConnectionFactory =
                new ActiveMQConnectionFactory(
                        ActiveMQConnectionFactory.DEFAULT_USER,
                        ActiveMQConnectionFactory.DEFAULT_PASSWORD,
//                        "tcp://192.168.0.100:61616");
                        ActiveMQConnectionFactory.DEFAULT_BROKER_URL);
        return activeMQConnectionFactory;
    }

}

注释掉的那行,可以用来指定activemq的broker地址。

接下来的Producer和Consumer与github上一样:

相关图片

相关文章