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协议的队列。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持毛票票。