zoukankan      html  css  js  c++  java
  • 使用代码创建rabbitmq交换机和队列绑定

    1、获取channel对象

    2、声明(创建)对列

    // 第一个参数,queueName:对列名称。数据类型:String
    // 第二个参数,durable:是否持久化, 队列的声明默认是存放到内存中的,如果rabbitmq重启会丢失,如果想重启之后还存在就要使队列持久化,保存到Erlang自带的Mnesia数据库中,当rabbitmq重启之后会读取该数据库。数据类型:boolean
    // 第三个参数,exclusive:是否排外的。数据类型:boolean
    // 第四个参数,autoDelete:是否自动删除。数据类型:boolean
    // 第五个参数,arguments:参数。数据类型:Map<String, Object>
    channel.queueDeclare(queueName, true, false, false, null);

    3、创建交换机

    // 第一个参数,exchange:交换机名称。数据类型:String
    // 第二个参数,type:交换机的类型(direct/topic/fanout)。数据类型:String
    channel.exchangeDeclare(exchange, type);

    4、绑定交换机和队列

    //第一个参数,queueName:对列名称。数据类型:String
    //第二个参数,exchange:交换机名称。数据类型:String
    //第三个参数,routingKey:队列跟交换机绑定的键值。数据类型:String
    channel.queueBind(queueName, exchange, routingKey);

     代码截图:

    上图的连接工厂的获取

     

  • 相关阅读:
    自己收集的一些伪元素/伪类
    ie9的placeholder不显示的解决办法(包含多个密码框)
    9.14上午
    9.13
    9.11笔记
    html基础英语单词
    选择器的分辨
    学习笔记
    RecyleView
    自定义view获取宽高
  • 原文地址:https://www.cnblogs.com/lu51211314/p/9591681.html
Copyright © 2011-2022 走看看