springboot2.0集成rabbitmq的示例代码
安装rabbitmq
简介:rabbitmq即一个消息队列,主要用来实现应用程序的异步和解耦,消息缓冲,消息分发的作用.
由于rabbitmq依赖于erlang语言,所以先安装erlang:
添加erlangsolutions源
$wgethttps://packages.erlang-solutions.com/erlang-solutions-1.0-1.noarch.rpm $sudorpm-Uvherlang-solutions-1.0-1.noarch.rpm $sudoyuminstallerlang
erlang完成后安装rabbitmq:
先下载rpm：
wgethttp://www.rabbitmq.com/releases/rabbitmq-server/v3.6.6/rabbitmq-server-3.6.6-1.el7.noarch.rpm
下载完成后安装：
yuminstallrabbitmq-server-3.6.6-1.el7.noarch.rpm
安装时如果遇到下面的依赖错误
Error:Package:socat-1.7.2.3-1.el6.x86_64(epel)
Requires:libreadline.so.5()(64bit)
可以尝试先执行
$sudoyuminstallsocat
rabbitmq的基本操作:
$sudochkconfigrabbitmq-serveron#添加开机启动RabbitMQ服务 $sudo/sbin/servicerabbitmq-serverstart#启动服务 $sudo/sbin/servicerabbitmq-serverstatus#查看服务状态 $sudo/sbin/servicerabbitmq-serverstop#停止服务 #查看当前所有用户 $sudorabbitmqctllist_users #查看默认guest用户的权限 $sudorabbitmqctllist_user_permissionsguest #由于RabbitMQ默认的账号用户名和密码都是guest。为了安全起见,先删掉默认用户 $sudorabbitmqctldelete_userguest #添加新用户 $sudorabbitmqctladd_userusernamepassword #设置用户tag $sudorabbitmqctlset_user_tagsusernameadministrator #赋予用户默认vhost的全部操作权限 $sudorabbitmqctlset_permissions-p/username".*"".*"".*" #查看用户的权限 $sudorabbitmqctllist_user_permissionsusername
开启远程访问
默认情况下，RabbitMQ的默认的guest用户只允许本机访问，如果想让guest用户能够远程访问的话，只需要将配置文件中的loopback_users列表置为空即可，如下：
{loopback_users,[]}
另外关于新添加的用户，直接就可以从远程访问的，如果想让新添加的用户只能本地访问，可以将用户名添加到上面的列表,如只允许admin用户本机访问。
{loopback_users,["admin"]}
更新配置后，重启服务.
###springboot2.0集成rabbitmq
pom引入start依赖:
org.springframework.boot spring-boot-starter-amqp
application.properties配置:
#rabbitmqconfigbegin #rabbitmq服务器地址（默认为127.0.0.1） spring.rabbitmq.host=127.0.0.1 #rabbitmq服务器连接端口（默认为5672） spring.rabbitmq.port=5672 spring.rabbitmq.username=admin spring.rabbitmq.password=123456 #rabbitmqconfigend
rabbitmqjavabean配置:
packagecom.snow.config;
importorg.springframework.amqp.core.Queue;
importorg.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
importorg.springframework.amqp.rabbit.connection.ConnectionFactory;
importorg.springframework.boot.autoconfigure.amqp.SimpleRabbitListenerContainerFactoryConfigurer;
importorg.springframework.context.annotation.Bean;
importorg.springframework.context.annotation.Configuration;
/**
*@Description:RabbitConfig
*@Author:爱飘de小子
*@CreateDate:2018/8/1519:59
*@Version:1.0
*/
@Configuration
publicclassRabbitConfig{
/**
*消费者数量，默认10
*/
publicstaticfinalintDEFAULT_CONCURRENT=10;
/**
*每个消费者获取最大投递数量默认50
*/
publicstaticfinalintDEFAULT_PREFETCH_COUNT=50;
/**
*注入Queue
*@return
*/
@Bean
publicQueueQueue(){
returnnewQueue("hello");
}
/**
*并发消费配置
*@paramconfigurer
*@paramconnectionFactory
*@return
*/
@Bean("pointTaskContainerFactory")
publicSimpleRabbitListenerContainerFactorypointTaskContainerFactory(SimpleRabbitListenerContainerFactoryConfigurerconfigurer,ConnectionFactoryconnectionFactory){
SimpleRabbitListenerContainerFactoryfactory=newSimpleRabbitListenerContainerFactory();
factory.setPrefetchCount(DEFAULT_PREFETCH_COUNT);
factory.setConcurrentConsumers(DEFAULT_CONCURRENT);
configurer.configure(factory,connectionFactory);
returnfactory;
}
}
发送消息:
/**
*注入AmqpTemplate
*/
@Autowired
privateAmqpTemplaterabbitTemplate;
publicvoidsendMessage(){
//发送消息
this.rabbitTemplate.convertAndSend("hello","你好,rabbitmq");
}
convertAndSend方法的第一个参数为QueueName,第二个参数为消息的内容
接收消息:
/**
*消息接受
*@parammessage
*/
@RabbitListener(queues="hello")//监听器监听指定的QueueName
publicvoidreceive(Stringmessage){
System.out.println("接收消息:"+message);
}
并发消费:
sendMessage()发送消息后,receive()接受消息,此时receive()接受消息,等待处理完成后,下一个消息才能进入receive(),如果想要消息异步消费,还需配置并发消费:
/**
*消息接受并发消费
*@parammessage
*/
@RabbitListener(queues="hello",containerFactory="pointTaskContainerFactory")
publicvoidreceive(Stringmessage){
System.out.println("接收消息:"+message);
}
@RabbitListener注解中的containerFactory是RabbitConfig配置的pointTaskContainerFactory,可以自定义如下参数:
/** *消费者数量，默认10 */ publicstaticfinalintDEFAULT_CONCURRENT=10; /** *每个消费者获取最大投递数量默认50 */ publicstaticfinalintDEFAULT_PREFETCH_COUNT=50;
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。