消息队列-RabbitMQ-简单模式(代码)-生产者

前提是已经有可用的rabbitmq服务端,如果还没有 参考安装 

消息队列-RabbitMQ-Centos8安装RabbitMQ_if_icanfly的博客-CSDN博客1.环境安装使用PackageCloud Yum Repository安装依次执行下面这两条命令curl -s https://packagecloud.io/install/repositories/rabbitmq/rabbitmq-server/script.rpm.sh | sudo bashcurl -s https://packagecloud.io/install/repositories/rabbitmq/erlang/script.rpm.sh | sudo bhttps://blog.csdn.net/if_icanfly/article/details/123252256?spm=1001.2014.3001.5502

如上官方图:简单模式只有一个生产者,一个队列,一个消费者 没有交换机 

 新建一个普通的maven项目.导入mq的依赖

pom.xml文件中添加以下依赖

      com.rabbitmq
      amqp-client
      5.9.0

以下是代码  

 public static void main(String[] args) throws IOException, TimeoutException {
        //1.创建连接工厂
        ConnectionFactory conn = new ConnectionFactory();
        //2.设置参数
        conn.setHost("127.0.0.1");
        conn.setPort(5672);
        // 使用默认的虚拟机
        conn.setVirtualHost("/");
        conn.setUsername("xiang");
        conn.setPassword("564409");
        //3.创建连接
        Connection connection = conn.newConnection();
        //4.创建channel
        Channel channel = connection.createChannel();
        //5.创建队列
        
        channel.queueDeclare("hello", true, false, false, null);
        //6.发送消息
        
        // 由于简单模式不需要交换机 所以这里交换机名称不填 路由key要跟上面创建的队列匹配 
        channel.basicPublish("","hello",null,"ceshi".getBytes());

        // 7.关闭资源
        channel.close();
        connection.close();
    }

由于简单模式是不需要交换机的 所以以上的代码没有创建交换机  

发送消息的时候 routingKey必须与队列名称完全匹配 否则消息无法到达队列 

创建一个maven项目,导入以下spring与spring整合mq的依赖以及测试依赖

        
            org.springframework
            spring-context
            5.2.1.RELEASE
        

        
            org.springframework
            spring-test
            5.2.1.RELEASE
        

        
            org.springframework.amqp
            spring-rabbit
            2.3.10
        

        
        
            junit
            junit
            4.13.1
            test
        

resource目录下新建一个配置文件spring-rabbitmq.xml 与mq.properties内容添加如下

 mq.properties(换成你自己的地址 密码 账号)

mq.host=127.0.0.1
mq.username=xiang
mq.password=564409
mq.port=5672
mq.vhost=/

spring-rabbitmq.xml 

上面的配置也只配置了连接工厂  连接 以及队列 还有生成的rabbitTemplate 并没有配置交换机

测试代码:

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = "classpath:applicationcontext.xml")
public class daxiang {

    @Resource
    private RabbitTemplate rabbitTemplate;

    @Test
    public void test(){
        // 这里的第一个参数 routingKey 与配置文件中配置的队列名称完全匹配
        rabbitTemplate.convertAndSend("spring_queue","测试简单模式");
    }
}

结果:

 控制台可以看到,新建了名字叫做spring_queue的队列 且里面有一条未消费的消息

新建一个springboot的项目

3.1导入springboot整合rabbitmq的依赖 在pom文件中添加依赖

        
            org.springframework.boot
            spring-boot-starter-amqp
            2.6.4
        

3.2在配置文件(application.properties)中添加链接工厂的参数

spring.rabbitmq.host=127.0.0.1
spring.rabbitmq.port=5672
spring.rabbitmq.username=xiang
spring.rabbitmq.password=564409
spring.rabbitmq.virtual-host=/

 3.3添加配置类 新建一个配置类RabbitMqConfig.java 在配置类中声明队列

import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.QueueBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitMqConfig {


    

    @Bean
    public Queue orderQueue(){
        return QueueBuilder.durable("order").build();
    }

}

测试:在测试列类中进行测试

@SpringBootTest
class DemoApplicationTests {

    @Resource
    private RabbitTemplate rabbitTemplate;

    @Test
    void contextLoads() {
        // 第一个参数是routingKey 需要与配置类中声明的队列名称完全匹配 后面为要发送的消息
        rabbitTemplate.convertAndSend("order","nihao ");
    }

}

结果: