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

     代码截图:

    上图的连接工厂的获取

     

  • 相关阅读:
    最少换乘
    hdu5441 Travel
    hdu 5444 Elven Postman(水)
    hdu5443 The Water Problem(水)
    hdu5438 Ponds
    poj 3281
    Light OJ
    2016中国大学生程序设计竞赛
    2016中国大学生程序设计竞赛
    UVA 10200 Prime Time (打表)
  • 原文地址:https://www.cnblogs.com/lu51211314/p/9591681.html
Copyright © 2011-2022 走看看