评论

收藏

[Java] springboot2.0集成rabbitmq的示例代码

编程语言 编程语言 发布于:2021-10-07 11:56 | 阅读数:541 | 评论:0

这篇文章主要介绍了springboot2.0集成rabbitmq的示例代码,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
安装rabbitmq
简介: rabbitmq即一个消息队列,主要用来实现应用程序的异步和解耦,消息缓冲,消息分发的作用.
由于rabbitmq依赖于erlang语言,所以先安装erlang:
添加erlang solutions源
$ wget https://packages.erlang-solutions.com/erlang-solutions-1.0-1.noarch.rpm
$ sudo rpm -uvh erlang-solutions-1.0-1.noarch.rpm
$ sudo yum install erlang
erlang完成后安装rabbitmq:
先下载rpm:
wget http://www.rabbitmq.com/releases/rabbitmq-server/v3.6.6/rabbitmq-server-3.6.6-1.el7.noarch.rpm
下载完成后安装:
yum install rabbitmq-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)
可以尝试先执行
$ sudo yum install socat
rabbitmq的基本操作:
$ sudo chkconfig rabbitmq-server on # 添加开机启动rabbitmq服务
 
$ sudo /sbin/service rabbitmq-server start # 启动服务
 
$ sudo /sbin/service rabbitmq-server status # 查看服务状态
 
$ sudo /sbin/service rabbitmq-server stop # 停止服务
 
#查看当前所有用户
 
$ sudo rabbitmqctl list_users
 
#查看默认guest用户的权限
 
$ sudo rabbitmqctl list_user_permissions guest
 
 
#由于rabbitmq默认的账号用户名和密码都是guest。为了安全起见, 先删掉默认用户
 
$ sudo rabbitmqctl delete_user guest
 
 
 
#添加新用户
 
$ sudo rabbitmqctl add_user username password
 
#设置用户tag
 
$ sudo rabbitmqctl set_user_tags username administrator
 
#赋予用户默认vhost的全部操作权限
 
$ sudo rabbitmqctl set_permissions -p / username ".*" ".*" ".*"
 
#查看用户的权限
 
$ sudo rabbitmqctl list_user_permissions username
开启远程访问
默认情况下,rabbitmq的默认的guest用户只允许本机访问, 如果想让guest用户能够远程访问的话,只需要将配置文件中的loopback_users列表置为空即可,如下:
{loopback_users, []}
另外关于新添加的用户,直接就可以从远程访问的,如果想让新添加的用户只能本地访问,可以将用户名添加到上面的列表, 如只允许admin用户本机访问。
{loopback_users, ["admin"]}
更新配置后,重启服务.
###springboot2.0集成rabbitmq
pom引入start依赖:
<dependency>
  <groupid>org.springframework.boot</groupid>
  <artifactid>spring-boot-starter-amqp</artifactid>
</dependency>
application.properties配置:
#rabbitmq config begin
# 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
#rabbitmq config end
rabbitmq javabean配置:
package com.snow.config;
import org.springframework.amqp.core.queue;
import org.springframework.amqp.rabbit.config.simplerabbitlistenercontainerfactory;
import org.springframework.amqp.rabbit.connection.connectionfactory;
import org.springframework.boot.autoconfigure.amqp.simplerabbitlistenercontainerfactoryconfigurer;
import org.springframework.context.annotation.bean;
import org.springframework.context.annotation.configuration;
 
/**
 * @description: rabbitconfig
 * @author: 爱飘de小子
 * @createdate: 2018/8/15 19:59
 * @version: 1.0
 */
@configuration
public class rabbitconfig {
 
  /**
   * 消费者数量,默认10
   */
  public static final int default_concurrent = 10;
 
  /**
   * 每个消费者获取最大投递数量 默认50
   */
  public static final int default_prefetch_count = 50;
 
 
  /**
   * 注入 queue
   * @return
   */
  @bean
  public queue queue() {
  return new queue("hello");
  }
 
 
  /**
   * 并发消费配置
   * @param configurer
   * @param connectionfactory
   * @return
   */
  @bean("pointtaskcontainerfactory")
  public simplerabbitlistenercontainerfactory pointtaskcontainerfactory(simplerabbitlistenercontainerfactoryconfigurer configurer, connectionfactory connectionfactory) {
  simplerabbitlistenercontainerfactory factory = new simplerabbitlistenercontainerfactory();
  factory.setprefetchcount(default_prefetch_count);
  factory.setconcurrentconsumers(default_concurrent);
  configurer.configure(factory, connectionfactory);
  return factory;
  } 
}
发送消息:
/**
 * 注入amqptemplate
 */
@autowired
private amqptemplate rabbittemplate;
 
 
 
public void sendmessage(){
  //发送消息
  this.rabbittemplate.convertandsend("hello","你好,rabbitmq");
}
convertandsend方法的第一个参数为queuename,第二个参数为消息的内容
接收消息:
/**
   * 消息接受
   * @param message
   */
  @rabbitlistener(queues = "hello") //监听器监听指定的queuename
  public void receive(string message) {
  system.out.println("接收消息:" + message);
  }
并发消费:
sendmessage() 发送消息后,receive() 接受消息,此时receive()接受消息,等待处理完成后,下一个消息才能进入receive(),如果想要消息异步消费,还需配置并发消费:
/**
   * 消息接受 并发消费
   * @param message
   */
  @rabbitlistener(queues = "hello",containerfactory = "pointtaskcontainerfactory")
  public void receive(string message) {
  system.out.println("接收消息:" + message);
  }
@rabbitlistener注解中的containerfactory 是rabbitconfig配置的pointtaskcontainerfactory,可以自定义如下参数:
/**
   * 消费者数量,默认10
   */
  public static final int default_concurrent = 10;
 
  /**
   * 每个消费者获取最大投递数量 默认50
   */
  public static final int default_prefetch_count = 50;
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持CodeAE代码之家
原文链接:https://juejin.im/post/5c0273b06fb9a049f06a0021

关注下面的标签,发现更多相似文章