阶段5 3.微服务项目【学成在线】_day05 消息中间件RabbitMQ_5.RabbitMQ研究-入门程序-生产者

2024-10-06 14:51:16

1）java client
生产者和消费者都属于客户端，rabbitMQ的java客户端如下：

我们先用 rabbitMQ官方提供的java client测试，目的是对RabbitMQ的交互过程有个清晰的认识。
参考：https://github.com/rabbitmq/rabbitmq-java-client/
2）创建maven工程
创建生产者工程和消费者工程，分别加入RabbitMQ java client的依赖。
test-rabbitmq-producer：生产者工程
test-rabbitmq-consumer：消费者工程

<dependency>

<groupId>com.rabbitmq</groupId>

<artifactId>amqp‐client</artifactId>

<version>4.0.3</version><!‐‐此版本与spring boot 1.5.9版本匹配‐‐>

</dependency>

<dependency>

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

<artifactId>spring‐boot‐starter‐logging</artifactId>

</dependency>

这是生产者

再件消费者工程

这样两个工程就都建立起来了

加入依赖

消费端也加入依赖

生产者

交换机是默认的，不用声明交换机，声明队列即可

Ctrl+T可以看到所有的实现类

看到实现类里面的参数

把上面那几个参数都复制过来

在最上面声明一个队列名称

之前在队列里面建过helloworld，

为了从头演示。把这个helloworld的删除掉

这样列表内就没了

这样一个最近本的队列声明就声明完了

生产者把消息发给交换机。关联默认的交换机。、
basicPublish

点进来。Ctrl+T 找到实现类

找到实现类的方法有一堆的参数

测试

报错‘

发送成功

这里自动创建了一个队列，helloworld

显示待发送的消息有一条。total消息总数也是1

总结

1、发送端操作流程
1）创建连接
2）创建通道
3）声明队列
4）发送消息

完成

最新文章

热门文章