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





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

    完成




     

  • 相关阅读:
    Java 的 多态和构造方法
    java 的 抽象类、接口
    java 的 封装 、继承
    eclipse的安装和基本使用、面向对象、类和对象
    方法的重载、引用数据类型、 ArrayList集合
    SQL单行函数
    JAVA
    mysql约束
    MYSQL的常用属性
    mysql的索引
  • 原文地址:https://www.cnblogs.com/wangjunwei/p/11598524.html
Copyright © 2011-2022 走看看