# 消息队列的简单使用 **Repository Path**: dingjunjun_codeSpace/rabbitmq ## Basic Information - **Project Name**: 消息队列的简单使用 - **Description**: 各种主流的消息队列的使用案例。 - **Primary Language**: Java - **License**: Apache-2.0 - **Default Branch**: master - **Homepage**: None - **GVP Project**: No ## Statistics - **Stars**: 0 - **Forks**: 36 - **Created**: 2023-04-20 - **Last Updated**: 2023-04-20 ## Categories & Tags **Categories**: Uncategorized **Tags**: None ## README # rabbitmq #### 项目介绍 对消息队列RabbitMQ简单的使用，以及编写一些示例。 #### 代码结构 ~~~ rabbitmq │ |- 父项目 ├─rabbitmq-helloword │ |- rabbitmq的入门示例，一个简单的生产者和消费者示例 │ 1、消费端消息的限流，(basicQos,必须要手动签收) ├─rabbitmq-advance │ |- rabbitmq的高级示例 ├──────── returnlistener(处理未被正确路由的消息 http://huan1993.iteye.com/blog/2429061) │ 1、mandatory：参数的使用 │ 2、用于获取到没有路由到消息队列中的消息。 │ 3、如果没有触发ReturnListener的注意事项(RabbitMQ配置的内存和磁盘限制) http://www.rabbitmq.com/alarms.html │──────── alternateexchange(处理未被正确路由的消息 http://huan1993.iteye.com/blog/2429061) │ 1、当消息从生产者交换器出发，没有合适的routingKey，那么会交给这个交换器的 备份交换器(alternate-exchange) │──────── defaultexchange(默认交换器) │ 1、默认的交换器是 "" ,并且是直连的交换器 │ 2、新建的队列默认会自动绑定到默认的交换器上，且routingKey是队列的名称 │──────── topic(topic交换器-发布订阅) │ 1、# 匹配一个或多个 │ 2、* 匹配一个 │ 3、eg: │ bindingKey : │ goods.* │ goods.# │ routingKey: │ goods.apple ==> 可以被上方2个都匹配上 │ goods.shopping.apple ==> 只可以被 goods.# 匹配上 │──────── produceconfirm(服务端消息确认 http://huan1993.iteye.com/blog/2432156) │ 有时候我们消息生产者，需要知道消息是否到达了RabbitMQ服务器，那么就需要进行消息确认了 │ |- confirmlistener(confirm异步确认) │ |- tx(事务确认) │──────── dlx(死信队列和延时队列的使用 ) │ |- 死信队列 和 延时消息 整合成一个延时队列的使用例子 ├─rabbitmq-spring │ |- spring和rabbitmq的整合示例（http://huan1993.iteye.com/blog/2432329） │ |- configuration rabbitmq和spring整合的配置 │ |- test 各种测试 │ |- DynamicSimpleMessageListenerContainerTest │ |- 测试动态的添加对队列的监听和移除对队列的监听 │ |- 还可以动态修改其它的属性 │ |- RabbitAdminService │ |- rabbitAdmin 的简单使用，比如创建队列删除队列等等 │ |- RabbitTemplateTest │ |- 使用rabbitTemplate发送消息等 ├─rabbitmq-springboot │ |- springboot整合rabbitmq（http://huan1993.iteye.com/blog/2432697） │ |- @RabbitListener 标注的方法中的bindings会自动进行创建队列、转换器和绑定等 │ |- 标注在类上： 为当前类中所有存在@RabbitHandler标注的方法服务 │ |- 标注在方法上：为每个方法创建一个监听容器 │ |- @RabbitHandler 标注的方法会使用用于处理接收到的消息 │ |- 如果是接收javabean，注意事项如下： │ > 1、方式一：发送方和接收方的发送的实体类必须实现序列化接口，并且包名需要相同 │ > 2、方式二：使用 @Payload 注解 │ > 3、方式三：使用自定义 MessageConverter可能需要重写里面的方法 │ > 4、上面的方式组合使用 ├─rabbitmq-springboot-advanced │ |- springboot整合rabbitmq（http://huan1993.iteye.com/blog/2432697） │ |- 使用@Bean方式自动实现队列、交换器、绑定的创建 │ |- 使用@RabbitListener实现队列消息的监听 │ |- 实现生产者消息确认 │ |- spring.rabbitmq.template.mandatory = true 设置成true │ |- spring.rabbitmq.publisher-confirms = true 设置成true │ |- 实现死信交换器（过期的消息、basic.nack或basic.reject且requeue参数为false或队列满的消息将进入此交换器） │ |- 申明队列的时候设置 x-dead-letter-exchange 参数 │ |- 实现备份交换器(alternate-exchange)，未被正确路由的消息将会经过此交换器 │ |- 申明交换器的时候设置 alternate-exchange 参数 │─使用docker搭建rabbitmq集群(https://blog.csdn.net/fu_huo_1993/article/details/102986327) │─RabbitMQ顺序消息消费，一个队列只有一个消费者 ├─rabbitmq-springboot-multi (https://blog.csdn.net/fu_huo_1993/article/details/107846901) │ |- springboot整合多个rabbitmq │ |- 配置多个RabbitMQ │ |- 往Spring容器中动态加入Bean │ |- 如果配置是从数据库中加载的，或则是通过CommandLineRunner来实现的，在需要调用SimpleMessageListenerContainer#start 方法 kafka ├─基本文章 │ |- 1、kafka集群的搭建(https://blog.csdn.net/fu_huo_1993/article/details/111089375) │ |- 2、kafka-eagle监控界面搭建(https://blog.csdn.net/fu_huo_1993/article/details/111982652) │ |- 3、kafka的基本概念(https://blog.csdn.net/fu_huo_1993/article/details/112111299) ├─kafka-api(https://blog.csdn.net/fu_huo_1993/article/details/112398024) │ |- 生产者 │ ｜- KafkaProducer线程安全的，可以在多线程中使用。 │ ｜- 消息发送的key和value的序列化 │ ｜- 自定义分区的使用 │ ｜- 自定义拦截器的使用 │ ｜- 消息发送完成后的回调使用 │ |- 消费者 │ ｜- 消息接收的key和value的序列化 │ ｜- 指定消费者组 │ ｜- 自动提交 offset (生产环境可以使用手动提交offset) │ ｜- 重置消费者的偏移量，此配置生效的条件 │ ｜- 自定义消息消费拦截器 │ ｜- 每次从服务器获取多少数据 ├─kafka-springboot(https://blog.csdn.net/fu_huo_1993/article/details/113482869) │ ｜- springboot 和 kafka 整合的一个小例子 │ ｜- 消费者消息的手动ack ~~~ #### 微信公众号 `更多内容请关注微信公众号` ![更多内容请关注微信公众号](./images/微信公众号.jpg)