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)发送消息

完成




 

相关文章:

  • 2021-05-31
  • 2022-03-06
  • 2022-01-31
  • 2021-08-26
  • 2022-02-04
  • 2022-03-05
  • 2021-09-20
  • 2021-10-04
猜你喜欢
  • 2021-08-12
  • 2021-08-02
  • 2022-01-14
  • 2021-11-29
  • 2021-08-02
  • 2021-12-20
  • 2021-09-20
相关资源
相似解决方案