Springboot之集成RabbitMQ

墨蓝 2022-06-06 10:19 212阅读 0赞

在集成RabbitMQ之前，首先需要安装RabbitMQ，我选择的是在centos上安装，具体的安装步骤请移步[在Centos7上安装RabbitMQ][Centos7_RabbitMQ]  
首先开始安装的第一步：  
1、修改pom.xml文件  
springboot对rabbitmq有很好的支持，提供了starter，支持自动配置

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>

--------------------

2、修改application.properties文件，添加rabbitmq的参数

#===============================rabbitmq配置===============================
    spring.rabbitmq.host=192.168.184.100
    spring.rabbitmq.port=5672
    spring.rabbitmq.username=root
    spring.rabbitmq.password=0.0.0.
    spring.rabbitmq.publisher-confirms=true  
    spring.rabbitmq.virtual-host=/

3、添加RabbitConfig.java，声明队列

@Configuration
    public class RabbitConfig { 
    
        public static String QUEUE_LOGINRECORD = "loginRecord";
    
        /* * 登录记录队列 */
        @Bean
        public Queue Queue() {
            return new Queue(RabbitConfig.QUEUE_LOGINRECORD);
        }
    
    }

--------------------

4、编写发送者，我这里是发送的是对象，其实发送对象和String是一样的操作，我这个示例的消息队列主要是完成登录成功时，用户的登录记录的保存操作

import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.amqp.core.AmqpTemplate;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Component;
    
    import com.cy.example.config.RabbitConfig;
    import com.cy.example.entity.LoginRecordEntity;
    
    
    @Component
    public class RabbitSender {
    
        private static final Logger logger = LoggerFactory
                .getLogger(RabbitSender.class);
    
        @Autowired
        private AmqpTemplate rabbitTemplate;
    
        public void send(LoginRecordEntity loginRecord) {
            logger.info("发送对象信息: " + loginRecord.toString());
            this.rabbitTemplate.convertAndSend(RabbitConfig.QUEUE_LOGINRECORD, loginRecord);
        }
    
    }

--------------------

5、编写监听者

import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.amqp.rabbit.annotation.RabbitListener;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.context.annotation.Configuration;
    
    import com.cy.example.entity.LoginRecordEntity;
    import com.cy.example.service.ILoginRecordService;
    
    @Configuration
    public class RabbitReceiver {
    
        private static final Logger logger = LoggerFactory
                .getLogger(RabbitReceiver.class);
    
        @Autowired
        private ILoginRecordService loginRecordService;
    
        @RabbitListener(queues = "loginRecord")
        public void process(LoginRecordEntity loginRecord) {
            logger.info("接收到object : " + loginRecord);
            loginRecordService.insert(loginRecord);
        }
    
    }

在这里我踩了不少的坑，一开始我编写的是

@Configuration
    @RabbitListener(queues = "loginRecord")
    public class RabbitReceiver { 
    
        private static final Logger logger = LoggerFactory
                .getLogger(RabbitReceiver.class);
    
        @Autowired
        private ILoginRecordService loginRecordService;
    
        @RabbitHandle//不知道为啥的这样写会一直报错监听失败，重复启动。网上查了一下，应该是springboot的starter写的有问题，
        public void process(LoginRecordEntity loginRecord) {
            logger.info("接收到object : " + loginRecord);
            loginRecordService.insert(loginRecord);
        }
    
    }

6、调用。

@Autowired  
    private RabbitSender sender;
    
    @SuppressWarnings("finally")
    @RequestMapping("/validate")
    @ResponseBody
    public Map<String, Object> validate(String username, String password) {
            Map<String, Object> map = new HashMap<String, Object>();
            password = MD5Util.GetMD5Code(password);
            UsernamePasswordToken usernamePasswordToken = new UsernamePasswordToken(
                    username, password);
            boolean flag = true;
            String msg = "";
            Subject subject = SecurityUtils.getSubject();
            try {
                subject.login(usernamePasswordToken); // 完成登录
                UserEntity user = (UserEntity) subject.getPrincipal();
                subject.getSession().setAttribute(WebConfig.LOGIN_USER, user);
                LoginRecordEntity loginRecord = new LoginRecordEntity();
                super.add(loginRecord);
                loginRecord.setC_loginIp(super.getIP(getRequest()));
                loginRecord.setC_username(user.getC_username());
    // loginRecordService.insert(loginRecord);
                //采用消息中心的通知添加
                sender.send(loginRecord);
                msg = "登陆成功！";
                map.put("flag", flag);
            } catch (Exception exception) {
                if (exception instanceof UnknownAccountException) {
                    logger.info("账号不存在： -- > UnknownAccountException");
                    msg = "登录失败，用户账号不存在！";
                } else if (exception instanceof IncorrectCredentialsException) {
                    logger.info(" 密码不正确： -- >IncorrectCredentialsException");
                    msg = "登录失败，用户密码不正确！";
                } else if (exception instanceof LockedAccountException) {
                    logger.info(" 用户被锁定： -- >LockedAccountException");
                    msg = "登录失败，用户被锁定！";
                } else {
                    logger.info("else -- >" + exception);
                    msg = "登录失败，发生未知错误：" + exception;
                }
                map.put("flag", false);
            } finally {
                map.put("msg", msg);
                return map;
            }
        }

最后提一下，在rabbitmq的web管理界面应该新建一个loginRecord的queue

--------------------

下面附上我的项目地址，想看源码 的可以去下载，对你有帮助请star[我的github地址][github]

[Centos7_RabbitMQ]: http://blog.csdn.net/qq_20989105/article/details/78387128
[github]: https://github.com/cy576013581/swallow