我们在使用Spring Cloud Stream时有三种情况:
- 本系统作为消息生产者
- 本系统作为消息消费者
- 本系统既是消息生产者又是消息消费者
相应的我们的测试也分三种情况, - 生产消息:这种情况下,我们只需要测试从指定的Binder中取出的消息是否符合预期就行了;
- 消费消息:这种情况下,我们需要给指定的Binder发送消息,消息驱动业务服务,然后检测对系统的影响是否符合预期;
- 既生产又消费:这种情况下,我们需要给指定的Binder发送消息,然后从指定的Binder中接收消息,判断此消息是否符合预期;
附上完整samples一个:spring-cloud-stream-test-samples