SpringBoot与缓存、消息、检索、任务、安全与监控

一、Spring抽象缓存Spring从3.1开始定义了org.springframework.cache.Cache和org.springframework.cache.CacheManager接口来统一不同的缓存技术;并支持使用JCache(JSR-107)注解简化开发。Cache接口为缓存的组件...

SpringBoot+STOMP 实现聊天室(单聊+多聊)及群发消息详解

SpringBoot+STOMP 实现聊天室(单聊+多聊)及群发消息详解

1、STOMP简介STOMP是WebSocket的子协议,STOMP即Simple (or Streaming) Text Orientated Messaging Protocol,简单(流)文本定向消息协议,它提供了一个可互操作的连接格式,允许STOMP客户端与任意STOMP消息代理(Broke...

微服务+全栈在线教育实战项目演练(SpringCloud Alibaba+SpringBoot)

307 课时 |
1466 人已学 |
免费

SpringBoot实战教程

59 课时 |
938 人已学 |
免费

SpringBoot快速掌握 - 核心技术

73 课时 |
9752 人已学 |
免费
开发者课程背景图

SpringBoot整合RocketMQ发送批量消息

发送限制生产者进行消息发送时可以一次发送多条消息,这样可以提升发送效率,需注意以下几点:批量发送的消息必须具有相同的Topic批量发送的消息必须具有相同的刷盘策略批量发送的消息不能是延时消息与事务消息批量发送大小默认情况下,一批发送的消息总大小不能超过4MB字节。如果想超出该值,有两种解决方案:方案...

SpringBoot整合RocketMQ发送事务消息

事务消息1. 概念分布式事务:一次操作由若干分支操作组成,这些分支操作分属不同应用,分布在不同服务器上。分布式事务需要保证这些分支操作要么全部成功,要么全部失败,分布式事务于普通事务一样,就是为了保证操作结果的一致性事务消息:RocketMQ提供了类似X/Open XA的分布式事务功能,通过事务消息...

SpringBoot整合RocketMQ发送延时消息

1. 延时等级延时时长不支持随意时长的延迟,是通过特定的延迟等级来指定的,默认变量有1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h,分别对应1~18等级。例如等级为3,对应于10s如果需要自己定义延时等级,需要在broker加载的...

SpringBoot整合RocketMQ发送顺序消息

1. 有序性分类根据有序范围的不同,可以分为两种消息的有序性:分区有序和全局有序分区有序有多个Queue参与,其仅可保证在该Queue分区队列上的消息顺序,称为分区有序在定义Producer时我们可以指定消息队列选择器,而这个选择器是我们自己实现了MessageQueueSelector接口定义的。...

SpringBoot整合RocketMQ发送普通消息

消息发送分类1、同步发送消息生产者发出一条消息后,会在收到MQ返回的ACK之后才发下一条消息。此类消息可靠性最高,但消息发送效率低2、异步发送消息生产者发出消息后无需等待MQ返回ACK,直接发送下一条消息。此类消息可靠性可以得到保障,消息发送效率也可3、单向发送消息生产者仅负责发送消息,不等待、不处...

SpringBoot学习笔记-10:第十章-SpringBoot 与消息

SpringBoot学习笔记-10:第十章-SpringBoot 与消息

第十章-SpringBoot 与消息JMS&AMQP 简介消息服务中间件可以提升系统异步通信,扩展解耦能力两个重要概念:消息代理 message broker目的地 destination队列 queue :点对点消息通信 point-to-point唯一的发送者和接收者主体 topic发布...

SpringBoot+RabbitMQ 实现手动消息确认(ACK)下

SpringBoot+RabbitMQ 实现手动消息确认(ACK)下

四、分析几个回执方法4.1、确认消息channel.basicAck(long deliveryTag, boolean multiple);我们一般使用下列方式:channel.basicAck( message.getMessageProperties().getDeliveryTag(), f...

SpringBoot+RabbitMQ 实现手动消息确认(ACK)上

SpringBoot+RabbitMQ 实现手动消息确认(ACK)上

一、前言前几天我研究了关于springboot整合简单消息队列,实现springboot推送消息至队列中,消费者成功消费。同时也加了消息转发器,对消息转发器各种类型的配置等做了总结。但是,主要还有一点,我一直存在疑问:如何确保消息成功被消费者消费?说到这里,我相信很多人会说使用ack啊...

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。