spring单元测试下模拟rabbitmq的实现
gradle添加引用
compile'org.springframework.boot:spring-boot-starter-amqp' testCompile'com.github.fridujo:rabbitmq-mock:1.0.10'
添加bean对象
/**
*模拟rabbitmq.
*/
@ActiveProfiles("test")
@Component
publicclassRabbitMqMock{
@Bean
publicConnectionFactoryconnectionFactory(){
returnnewCachingConnectionFactory(MockConnectionFactoryFactory.build());
}
}
添加测试的队列
publicstaticfinalStringLIND_EXCHANGE="test.basic.exchange";
publicstaticfinalStringLIND_QUEUE_ROUTEKEY="test.basic.*";
publicstaticfinalStringLIND_QUEUE_ROUTEKEY1="test.basic.a1";
publicstaticfinalStringLIND_QUEUE_ROUTEKEY2="test.basic.a2";
/**
*创建普通交换机.
*/
@Bean
publicTopicExchangelindExchange(){
return(TopicExchange)ExchangeBuilder.topicExchange(LIND_EXCHANGE).durable(true)
.build();
}
@Bean
publicQueuekey1(){
returnnewQueue(LIND_QUEUE_ROUTEKEY1);
}
@Bean
publicQueuekey2(){
returnnewQueue(LIND_QUEUE_ROUTEKEY2);
}
/**
*绑定了routekey，一个routekey可以被多个队列绑定，类似于广播.
*
*@return
*/
@Bean
publicBindingbindBuildersRouteKey1(){
returnBindingBuilder.bind(key1())
.to(lindExchange())
.with(LIND_QUEUE_ROUTEKEY);
}
/**
*bind.
*
*@return
*/
@Bean
publicBindingbindBuildersRouteKey2(){
returnBindingBuilder.bind(key2())
.to(lindExchange())
.with(LIND_QUEUE_ROUTEKEY);
}
@Autowired
privateRabbitTemplaterabbitTemplate;
/**
*发送拨打电话消息.
*/
publicvoidpublish(Stringmessage){
try{
rabbitTemplate
.convertAndSend(MqConfig.LIND_EXCHANGE,MqConfig.LIND_QUEUE_ROUTEKEY,
message);
}catch(Exceptione){
e.printStackTrace();
}
}
/**
*subscriber.
*
*@paramdata.
*/
@RabbitListener(queues=MqConfig.LIND_DEAD_QUEUE)
publicvoidcustomerSign(Stringdata){
try{
logger.info("从队列拿到数据：{}",data);
}catch(Exceptionex){
logger.error("签约同步异常",ex);
}
}
总结：通过上面的几行代码，我们可以对rabbitmq队列在测试环境中去模拟，方便了我们的测试，而这种方法比org.apache.qpid:qpid-broker:6.1.2这个包要方便的多，当然这个包也支持其它的qpid协议的队列。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。