RabbitMQ中的HelloWord模式demo

雨点打透心脏的1/2处 2022-10-23 15:24 98阅读 0赞

## 1.导入依赖 ##

<dependency>
        <groupId>com.rabbitmq</groupId>
        <artifactId>amqp-client</artifactId>
        <version>5.7.2</version>
    </dependency>

## 2.生产者测试代码 ##

import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    import com.rabbitmq.client.MessageProperties;
    import org.junit.Test;
    import utils.RabbitMQUtils;
    
    import java.io.IOException;
    import java.util.concurrent.TimeoutException;
    
    public class Provider { 
    
        @Test
        public void testSendMessage() throws IOException, TimeoutException { 
    /* //创建连接mq的连接工厂对象 ConnectionFactory connectionFactory = new ConnectionFactory(); //设置连接rabbitmq主机 connectionFactory.setHost("192.168.10.131"); //设置端口号 connectionFactory.setPort(5672); //设置连接那个虚拟主机 connectionFactory.setVirtualHost("/tututu"); //设置访问虚拟主机的用户名和密码 connectionFactory.setUsername("tututu"); connectionFactory.setPassword("123456"); //获取连接对象 Connection connection = connectionFactory.newConnection();*/
    
            //通过工具类获取连接对象
            Connection connection = RabbitMQUtils.getConnection();
    
            //获取连接中通道
            Channel channel = connection.createChannel();
    
            //通道绑定对应消息队列
            //参数1: 队列名称 如果队列不存在自动创建
            //参数2: 用来定义队列特性是否要持久化 true 持久化队列 false 不持久化
            //参数3: exclusive 是否独占队列 true 独占队列 false 不独占
            //参数4: autoDelete: 是否在消费完成后自动删除队列 true 自动删除 false 不自动删除
            //参数5: 额外附加参数
            channel.queueDeclare("hello",true,false,false,null);
    
            //发布消息
    
            //参数1: 交换机名称 参数2:队列名称 参数3:传递消息额外设置 参数4:消息的具体内容
            channel.basicPublish("","hello", MessageProperties.PERSISTENT_TEXT_PLAIN,"hello rabbitmq".getBytes());
    
    
            /*channel.close(); connection.close();*/
    
            //调用工具类
            RabbitMQUtils.closeConnectionAndChanel(channel,connection);
        }
    }