Java单元测试：使用RabbitMQ mock库完成消息生产和消费的mock模拟

2020-11-28 22:58:21 阅读：435 来源： 互联网

单元测试第二篇，演示在单元测试时，RabbitMQ生产者和消费者的mock。
相关代码已经放在Github上：源代码

要注意的是，因为不是真实的消息队列中间件，只是进程内mock，
因此，生产的消息无法被其它服务（进程）消费，消费者也无法收到真实的MQ消息。

下面简述开发过程：
1、首先，还是正常建立项目，并有常规的生产消息或消费消息的业务逻辑；

2、项目添加mock库的引用，打开pom.xml，添加：

<dependency>
    <groupId>com.github.fridujo</groupId>
    <artifactId>rabbitmq-mock</artifactId>
    <version>1.1.1</version>
    <scope>test</scope>
</dependency>

注：scope为test，是仅在单元测试时引入，运行时并不引入。

3、application.yml配置文件无需修改，会自动在Bean生成拦截。
注：为保险起见，建议新建unittest的配置节，把mq的ip改掉，避免mock不生效，导致误发或报错

4、在单元测试的package下新建配置类，拦截RabbitMQ的拦截类：

@Configuration
public class MockRabbitConfig {
    @Bean
    ConnectionFactory connectionFactory() {
        return new CachingConnectionFactory(new MockConnectionFactory());
    }
}

5、好了，现在可以直接对项目进行测试了，所有的生产者消息，都会发到内存，而不会到真正的RabbitMQ。
如果项目里有消费者，消费自己项目里生产的消息，也能正常收到消息，并消费。

如果你在运行时有问题，可以下载上面的源码，进行对比，看看你的代码哪里有问题。

标签：消费,Java,单元测试,RabbitMQ,消息,拦截,mock
来源： https://blog.csdn.net/youbl/article/details/110294743

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

Java单元测试：使用RabbitMQ mock库完成消息生产和消费的mock模拟