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)发送消息
转载于:https://www.cnblogs.com/wangjunwei/p/11598524.html