spring-boot-starter-stream-rabbit

<dependency>
    <groupId>com.kancy</groupId>
    <artifactId>spring-boot-starter-stream-rabbit</artifactId>
    <version>${version}</version>
</dependency>

#定义命名空间
stream.rabbit.project=test

#定义交换机
stream.rabbit.exchange.schedule.name=test.schedule
stream.rabbit.exchange.schedule.type=direct

#定义队列，并且绑定交换机
stream.rabbit.binding-queue.polling.name=test.schedule.polling
stream.rabbit.binding-queue.polling.exchange-name=test.schedule
stream.rabbit.binding-queue.polling.routing-key=polling

#定义队列，并且绑定交换机
stream.rabbit.binding-queue.five-seconds.name=test.schedule.five-seconds
stream.rabbit.binding-queue.five-seconds.exchange-name=test.schedule
stream.rabbit.binding-queue.five-seconds.routing-key=five-seconds
stream.rabbit.binding-queue.five-seconds.dlx-exchange-name=test.schedule
stream.rabbit.binding-queue.five-seconds.dlx-routing-key=polling
stream.rabbit.binding-queue.five-seconds.ttl=5s

#配置Rabbitmq连接信息
spring.rabbitmq.host=kancy.top
spring.rabbitmq.port=5672
spring.rabbitmq.username=root
spring.rabbitmq.password=****
spring.rabbitmq.virtual-host=/test
spring.rabbitmq.publisher-confirms=true
spring.rabbitmq.publisher-returns=true
spring.rabbitmq.template.mandatory=true

stream.rabbit:
  channel:
    polling:
      binding-key: polling
      concurrency: 2
      consumer:
        user-message:
          message-handler: user
    five-seconds:
      binding-key: five-seconds

/**
 * PollingChannelMessage
 *
 * @author kancy
 * @date 2020/3/8 16:51
 */
@ChannelKey("polling")
public class PollingChannelMessage extends AbstractChannelMessage {

}

/**
 * UserMessageHandler
 *
 * @author kancy
 * @date 2020/3/8 20:22
 */
@Component
public class UserMessageHandler implements MessageHandler<User> {
    private static Logger log = LoggerFactory.getLogger(UserMessageHandler.class);
    /**
     * 监听消息
     *
     * @param payload
     * @throws Exception
     */
    @Override
    public void onMessage(User payload) {
        log.info("接收信息：{}" , payload);
    }
}

@RunWith(SpringRunner.class)
@SpringBootTest(classes = {RabbitMessageChannelAutoConfiguration.class, RabbitAutoConfiguration.class, UserMessageHandler.class})
@ActiveProfiles({"test"})
public class MessageChannelServiceTests {

    @Autowired
    private MessageChannelService messageChannelService;

    @Test
    public void sendPollingChannelMessageTest(){
        ChannelMessage channelMessage = new PollingChannelMessage();
        channelMessage.setMessageType("user-message");
        channelMessage.setPayload(new User());
        messageChannelService.sendMessage(channelMessage);
    }

    @Test
    public void sendMessageTest(){
        // 手动指定channelKey
        String channelKey = "five-seconds";
        ChannelMessage channelMessage = new SimpleChannelMessage(channelKey);
        channelMessage.setMessageType("user-message");
        channelMessage.setPayload(new User());
        messageChannelService.sendMessage(channelMessage);
    }
}