springboot实现rabbitmq的队列初始化和绑定

/**

   * rabbitmq里初始化exchange.

   *

   * @return

   */

  @bean

  public topicexchange crmexchange() {

   return new topicexchange(exchange);

  }

/**

   * rabbitmq里初始化队列crm.hello.

   *

   * @return

   */

  @bean

  public queue helloqueue() {

   return new queue(hello);

  }

/**

   * 绑定exchange & queue & routekey.

   *

   * @param queuemessage 队列

   * @param exchange   交换机

   * @param routekey   路由

   * @return

   */

  public binding bindingexchange(queue queuemessage, topicexchange exchange, string routekey) {

   return bindingbuilder.bind(queuemessage).to(exchange).with(routekey);

  }

spring:

   rabbitmq:

   host: localhost

   port: 5672

   username: guest

   password: guest

   virtual-host: lind

package com.lind.microservice.productcenter.mq;

import org.springframework.amqp.core.binding;

import org.springframework.amqp.core.bindingbuilder;

import org.springframework.amqp.core.queue;

import org.springframework.amqp.core.topicexchange;

import org.springframework.context.annotation.bean;

import org.springframework.context.annotation.configuration;

/**

  * amqp配置.

  */

@configuration

public class amqpconfig {

  /**

   * 交换机.

   */

  public final static string exchange = "crm" ;

  /**

   * hello队列.

   */

  public final static string hello = "crm.hello" ;

  /**

   * 建立订单队列.

   */

  public final static string lind_generate_order = "crm.generate.order" ;

  /**

   * 绑定exchange & queue & routekey.

   *

   * @param queuemessage 队列

   * @param exchange   交换机

   * @param routekey   路由

   * @return

   */

  public binding bindingexchange(queue queuemessage, topicexchange exchange, string routekey) {

   return bindingbuilder.bind(queuemessage).to(exchange).with(routekey);

  }

  /**

   * rabbitmq里初始化exchange.

   *

   * @return

   */

  @bean

  public topicexchange crmexchange() {

   return new topicexchange(exchange);

  }

  /**

   * rabbitmq里初始化队列crm.hello.

   *

   * @return

   */

  @bean

  public queue helloqueue() {

   return new queue(hello);

  }

  /**

   * rabbitmq里初始化队列crm.generate.order.

   *

   * @return

   */

  @bean

  public queue orderqueue() {

   return new queue(lind_generate_order);

  }

}

package com.lind.microservice.productcenter.mq;

import java.util.date;

import org.springframework.amqp.core.amqptemplate;

import org.springframework.beans.factory.annotation.autowired;

import org.springframework.context.annotation.configuration;

@configuration

public class hellopublisher {

  @autowired

  amqptemplate rabbittemplate;

  @autowired

  amqpconfig amqpconfig;

  public void hello() {

   string context = "hello " + new date();

   system.out.println( "hellopublisher : " + context);

   amqpconfig.bindingexchange(

     amqpconfig.helloqueue(),

     amqpconfig.crmexchange(),

     "crm.hello.#"

   );

   this .rabbittemplate.convertandsend(amqpconfig.exchange, amqpconfig.hello, context);

  }

}

package com.lind.microservice.productcenter.mq;

import org.springframework.amqp.rabbit.annotation.rabbithandler;

import org.springframework.amqp.rabbit.annotation.rabbitlistener;

import org.springframework.stereotype.component;

@component

@rabbitlistener (queues = amqpconfig.hello)

public class hellosubscriber {

  @rabbithandler

  public void process(string hello) {

   system.out.println( "hellosubscriber : " + hello);

  }

}