1.安装rabbitmq

推荐使用docker安装rabbitmq, 简单快速。

######安装docker

#下载docker-ce的yum源

(yum -y install wget #安装wget)

wget -O /etc/yum.repos.d/docker-ce.repo https://mirrors.tuna.tsinghua.edu.cn/docker-ce/linux/centos/docker-ce.repo

#把docker-ce源的地址修改为清华源的地址

sed -i 's#download.docker.com#mirrors.tuna.tsinghua.edu.cn/docker-ce#g' /etc/yum.repos.d/docker-ce.repo

#更新docker-ce.repo

yum makecache fast

#安装docker-ce

yum install -y docker-ce

#启动

systemctl start docker

#检查是否安装成功

ps -ef |grep docker

docker version

######docker 安装 rabbitmq

#下载镜像

docker pull rabbitmq:3.8.12-management-alpine

#查看所有镜像

docker images

#启动Rabbit MQ容器

docker run -d --hostname rabbit_host1 --name rabbit -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin -p 15672:15672 -p 5672:5672 rabbitmq:3.8.12-management-alpine

#管理页面

http://127.0.0.1:15672

2.推送消息给rabbitmq

###springboot集成rabbitmq

#引入依赖

<dependency>

            <groupId>org.springframework.boot</groupId>

            <artifactId>spring-boot-starter-amqp</artifactId>

</dependency>

#application.properties

server.servlet.context-path=/event

spring.application.name=event-send

server.port = 8090

spring.rabbitmq.addresses=7.211.2.3:5672,7.211.2.4:5672,7.211.2.5:5672

spring.rabbitmq.port=5672

spring.rabbitmq.username=admin

spring.rabbitmq.password=123456

spring.rabbitmq.virtual-host=cmp

spring.rabbitmq.dynamic=true

#配置类RabbitConfig

package com.enmotech.event.send;

import org.springframework.amqp.core.Queue;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

@Configuration

public class RabbitConfig {

    @Bean

    public Queue Queue() {

        return new Queue("bocloud.dbm.alarm.queue");

    }

}

#生产者类(发送)SendToRabbitMq

package com.enmotech.event.send;

import com.alibaba.fastjson.JSON;

import com.alibaba.fastjson.JSONObject;

import lombok.extern.slf4j.Slf4j;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.amqp.core.Message;

import org.springframework.amqp.core.MessageBuilder;

import org.springframework.amqp.rabbit.core.RabbitTemplate;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.web.bind.annotation.*;

/**

* @date ：2021/6/24 16:50

*/

@Slf4j

@RestController

@RequestMapping("/mq")

public class SendToRabbitMq {

    private static final Logger LOGGER = LoggerFactory.getLogger(SendToRabbitMq.class);

    private final static String QUEUE_NAME = "bocloud.dbm.alarm.queue";

    private final static String KEY="eventStatus";

    @Autowired

    private RabbitTemplate rabbitTemplate;

    @GetMapping("/test")

    public String test() {

        LOGGER.info("test...");

        return "success!";

    }

    @PostMapping("/send")

    public String send(@RequestBody String msg) {

        LOGGER.info("ready to send,msg={}",msg);

        JSONObject jsonObject = JSON.parseObject(msg);

        String message = JSON.toJSONString(jsonObject);

        Message m  = MessageBuilder.withBody(message.getBytes())

                .setContentType("text/json")

                .setContentEncoding("UTF-8")

//                .setMessageId(UUID.randomUUID() + "")

                .build();

        rabbitTemplate.convertAndSend(QUEUE_NAME,m);

        LOGGER.info("send complete!");

        return "send success";

    }

}