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);

     代码截图:

    上图的连接工厂的获取

     

  • 相关阅读:
    手机号码 正则表达式
    邮政编码的正则表达式
    对象为null,调用非静态方法产生空指针异常
    文件找不到异常(FileNotFoundException)
    数组下标越界异常解决方法
    空指针异常的解决方法
    需求:打印九九乘法表
    创建简单线程
    ·博客作业06--图
    博客作业05--查找
  • 原文地址:https://www.cnblogs.com/lu51211314/p/9591681.html
Copyright © 2011-2022 走看看