centos 部署rabbitmq，java项目使用

一 部署服务

1.部署：

        docker-compose 部署rabbitmq

        配置文件docker-compose.yml:

        linux命令;vim docker-compose.yml

version: '3'
services:
  rabbitmq:
    image: rabbitmq:management-alpine
    container_name: rabbitmq
    environment:
      - RABBITMQ_DEFAULT_USER=admin
      - RABBITMQ_DEFAULT_PASS=123456
      - SET_CONTAINER_TIMEZONE=true
      - CONTAINER_TIMEZONE=Asia/Shanghai
    restart: always
    ports:
      - "15672:15672"
      - "5672:5672"
      - "61613:61613"
    volumes:
      - ./data/:/var/lib/rabbitmq
    logging:
      driver: "json-file"
      options:
        max-size: "200k"
        max-file: "10"

2.启动

        linux命令：docker-compose up -d

3.测试部署

        访问:   IP:+15672

        账号：admin    ; 密码：123456

二 java 测试类

1.生产者：

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
 
import java.io.IOException;
import java.util.concurrent.TimeoutException;
 

public class Producer
{
    public final static String QUEUE_NAME = "test";
 
    public static void main(String[] args) throws IOException, TimeoutException
    {
        //创建连接工厂
        ConnectionFactory factory = new ConnectionFactory();
 
        //设置RabbitMQ相关信息
        factory.setHost("192.168.3.45");
        factory.setVirtualHost("/");
        factory.setUsername("admin");
        factory.setPassword("admin");
        factory.setPort(5672);
 
        //创建一个新的连接
        Connection connection = factory.newConnection();
 
        //创建一个通道
        Channel channel = connection.createChannel();
 
        // 声明一个队列
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);
 
        //发送消息到队列中
        String message = "Hello RabbitMQ";
        channel.basicPublish("", QUEUE_NAME, null, message.getBytes("UTF-8"));
        System.out.println("Producer Send +'" + message + "'");
 
        //关闭通道和连接
        channel.close();
        connection.close();
    }
}

2.消费者

import com.rabbitmq.client.*;
 
import java.io.IOException;
import java.util.concurrent.TimeoutException;
 

public class Customer
{
    private final static String QUEUE_NAME = "test";
 
    public static void main(String[] args) throws IOException, TimeoutException
    {
        // 创建连接工厂
        ConnectionFactory factory = new ConnectionFactory();
 
        //设置RabbitMQ地址
        factory.setHost("192.168.3.45");
        factory.setVirtualHost("/");
        factory.setUsername("admin");
        factory.setPassword("admin");
 
        //创建一个新的连接
        Connection connection = factory.newConnection();
 
        //创建一个通道
        Channel channel = connection.createChannel();
 
        //声明要关注的队列
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);
        System.out.println("Customer Waiting Received messages");
 
        // 告诉服务器我们需要那个频道的消息，如果频道中有消息，就会执行回调函数handleDelivery
        Consumer consumer = new DefaultConsumer(channel)
        {
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException
            {
                String message = new String(body, "UTF-8");
                System.out.println("Customer Received '" + message + "'");
            }
        };
        //自动回复队列应答 -- RabbitMQ中的消息确认机制
        channel.basicConsume(QUEUE_NAME, true, consumer);
    }
}

3.pom文件

        
            com.rabbitmq
            amqp-client
            5.0.0
        

        
            org.springframework.amqp
            spring-rabbit
            2.0.2.RELEASE
        

        
            org.springframework.boot
            spring-boot-starter-web
        

        
            org.springframework.boot
            spring-boot-starter-amqp
        
        
            org.projectlombok
            lombok
            1.18.12
        
        
            com.spotify
            docker-client
            5.0.1
        
        
            com.alibaba
            fastjson
            1.2.69
        
        
            com.google.guava
            guava
            20.0
        
        
            com.google.code.gson
            gson
            2.8.5
        
    

备注：java 实体转String ,String转实体

实体转String

ObjectMapper objectMapper = new ObjectMapper(); //json
Test test = new Test();
test.setId(1);
test.setUnitName("ssss");
test.setUnitSn("aaaa");
String s = objectMapper.writevalueAsString(test);



String转实体
Test newsList2 = new Gson().fromJson(message, new TypeToken() {}.getType());



备注List对象一样 使用