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

     代码截图:

    上图的连接工厂的获取

     

  • 相关阅读:
    java学习网址大全
    Js 提示框
    api帮助文档及常见IT学习网站
    传参给 jsp
    jsp>action
    二级横菜单显示+sitemesh母板应用
    request,session
    map>json
    清空image画布并改变大小填充背景色
    取汉字首字母方法
  • 原文地址:https://www.cnblogs.com/lu51211314/p/9591681.html
Copyright © 2011-2022 走看看