easy-rabbitmq

// 生产端
// 定义接口继承BaseProducer
// 加上@Rqueue注解

// Простой режим очереди
@Rqueue(queue = "q")
public interface Q1 extends BaseProducer<String> {

}

// Использование обменника
@Rqueue(queue = "q", exchange = "e")
public interface Q2 extends BaseProducer<CustomObject> {

}

// Добавление ключа маршрутизации
@Rqueue(queue = "q", exchange = "e", routing = "r")
public interface Q3 extends BaseProducer<byte[]> {

}

// Установка режима распределения
@Rqueue(queue = "q", exchange = "e", routing = "r", exchangeType = "direct")
public interface Q4 extends BaseProducer<String> {

}

// Настройка пути сканирования интерфейса
@RqueueScan("xxx.xxx")
@Configuration
public class RabbitConfiguration {
}

@Component
public class Demo {

  @Autowired
  Q1 q1;
  @Autowired
  Q2 q2;
  @Autowired
  Q3 q3;
  @Autowired
  Q4 q4;

  @PostConstruct
  private void init(){
    q1.send("hello world");
    q2.send(new CustomObject());
    q3.send("hello world".getBytes());
    q4.send("hi");
  }
}


// Потребительский конец
// Изменение файла конфигурации, по умолчанию false не включено
spring.rabbitmq.listener.enabled=true

// Реализация Customer интерфейса и добавление @Rqueue аннотации

@Rqueue(queue = "q", exchange = "3")
public class StrMessageProcess implements Consumer<CustomObject> {

  @Override
  public void accept(CustomObject message) {
    System.out.println(message);
  }
}

// Другие настройки (см. официальную конфигурацию Springboot)
spring:
  rabbitmq:
    host: 10.10.30.137
    port: 5672
    username: dev
    password: 123456
    listener:
      enabled: true