• 2024-11-09SpringAMQP — RabbitMQ操作工具
    1.SpringAMQP简介SpringAMQP(SpringforAdvancedMessageQueuingProtocol)是Spring框架的一个子项目,用于简化与消息代理(如RabbitMQ)的集成。SpringAMQP提供了基于AMQP协议的抽象层,使得Java程序员能够更轻松地使用消息队列完成异步通信、消息分发和数据流处理。S
  • 2024-10-26RabbitMQ 入门(三)SpringAMQP消息转换器
    一、消息转换器Spring会把你发送的消息序列化为字节发送给MQ,接收消息的时候,还会把字节反序列化为Java对象。只不过,默认情况下Spring采用的序列化方式是JDK序列化。众所周知,JDK序列化存在下列问题:-数据体积过大-有安全漏洞-可读性差JDK序列化方
  • 2024-08-07SpringAMQP的简要实现
    1.BasicQueue简单队列模型1.1导入依赖<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency>1.2yamlspring:rabbitmq:host:192.168.150.101#主机名
  • 2024-07-02SpringAMQP
    快速入门在之前的案例中,我们都是经过交换机发送消息到队列,不过有时候为了测试方便,我们也可以直接向队列发送消息,跳过交换机。在入门案例中,我们就演示这样的简单模型,如图:也就是:publisher直接发送消息到队列消费者监听并处理队列中的消息:::warning注意:这种模式一般测试使
  • 2024-06-09【RabbitMQ】SpringAMQP--消息转换器
    在SpringAMQP的发送方法中,接收消息的类型是 Object,也就是说我们可以发送任意对象类型的消息,SpringAMQP会帮我们序列化为字节后发送。测试发送Object类型消息1.声明队列@ConfigurationpublicclassFanoutConfig{@BeanpublicQueueobjectQueue(){return
  • 2024-06-08SpringAMQP使用管理RabbitMQ的五种消息模型
    使用SpringAMQ实现五种消息队列模型1.普通队列2.工作队列(WorkQueue)发布订阅=>根据交换机的不同分为三种3.订阅模型之Fanout(广播)4.订阅模型之Direct(路由)5.订阅模型之Topic(话题)使用前导:1.在生产者和消费者项目上分别导入RabbitMQ依赖<!--AMQP依赖,包含RabbitMQ-->
  • 2024-06-05SpringAMQP的工作队列WorkQueue
    Workqueue,工作队列,可以提高消息处理速度,避免队列消息堆积 模拟WorkQueue,实现一个队列绑定多个消费者基本思路如下:在publisher服务中定义测试方法,每秒产生50条消息,发送到simple.queue在consumer服务中定义两个消息监听者,都监听simple.queue队列一个消息监听者每秒处理50条消
  • 2024-03-30SpringAMQP
    SpringAMQPSpringAMQP是基于RabbitMQ封装的一套模板,并且还利用SpringBoot对其实现了自动装配,使用起来非常方便。SpringAmqp的官方地址:https://spring.io/projects/spring-amqpAdvancedMessageQueuingProtocol,是用于在应用程序之间传递业务消息的开放标准。该协议与语言和平
  • 2024-03-06利用SpringAMQP依赖使用RabbitMQ
    消息消费端和提供端需要引入依赖<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId></dependency>都需要在application.yml进行如下配置spring:rabbitmq:host:192.168.230.100#r
  • 2024-01-15SpringAMQP(十三)
    什么是SpringAMQPSpringAMQP的官方地址:https://spring.io/projects/spring-amqpAMQP(AdvancedMessageQueuingProtocol):是用于在应用程序或之间传递业务消息的开放标准。该协议与语言和平台无关,更符合微服务中独立性的要求。SpringAMQP:SpringAMQP是基于AMQP协议定义的一套AP
  • 2023-10-08springAMQP--DirectExchange(在监听方法上用注解声明交换机队列和key,发送消息时会带一个key,发送到交换机后,交换机会根据key去匹配队列,将消息发送到有相同key的队列中
         
  • 2023-10-07springAMQP-Work Queue 工作队列(一个队列绑定多个消费者)
         
  • 2023-10-07SpringAMQP—入门案例消息发送(rabbitmq是一个存放消息队列的中转站,发布者将消息队列发送到上面后,订阅者在rabbitmq上订阅消息并定义行为处理消息)
        
  • 2023-08-30SpringAMQP--消息转换器
        
  • 2023-08-30SpringAMQP--TopicExchange
             
  • 2023-08-30SpringAMQP-WorkQueue模型
          
  • 2023-06-28RabbitMQ消息持久化
    我们看下之前启动idea测试消息发送的时候在后台生成的一条消息,现在已经在消息队列里面还没有被消费。 现在我们重启下RabbitMQ,执行linux命令:dockerrestartmq看上图实时显示的错误信息,失去连接了,接下来刷新这个页面,可以发现这个对象没有了。 说明rabbit消息并不会持久化,不
  • 2022-12-27springAMQP
                                                       
  • 2022-12-05SpringAMQP
    SpringAMQP是基于RabbitMQ封装的一套模板,并且还利用SpringBoot对其实现了自动装配,使用起来非常方便。SpringAmqp的官方地址:https://spring.io/projects/spring-amqp S