- 综合排序
- 最热优先
- 最新优先
- 来自专栏dongfanger
SpringBoot官方笔记6消息
The Spring Framework provides extensive support for integrating with messaging systems, from simplified use of the JMS API using JmsTemplate to a complete infrastructure to receive messages asynchronously. Spring AMQP provides a similar feature set for the Advanced Message Queuing Protocol. Spring Boot also provides auto-configuration options for RabbitTemplate and RabbitMQ. Spring WebSocket natively includes support for STOMP messaging, and Spring Boot has support for that through starters and a small amount of auto-configuration. Spring Boot also has support for Apache Kafka.
28720编辑于 2023-07-20 - 来自专栏菩提树下的杨过
ActiveMQ笔记(6)：消息延时投递
在开发业务系统时，某些业务场景需要消息定时发送或延时发送（类似：飞信的短信定时发送需求），这时候就需要用到activemq的消息延时投递，详细的文档可参考官网说明，本文只介绍二种常用的用法： 注：本文采用 spring的JmsTemplate来发送消息 步骤1、首先要修改activemq.xml配置文件，启用延时投递 1 <broker xmlns="http://activemq.apache.org/ ： 在scheduled面板中，可以看到延时的<em>消息</em> ? 注：在开启<em>消息</em>持久化存储的前提下，就算把相应的queue在webconsole面板中删除（即删除队列），只要投递的时间尚未到，该<em>消息</em>也不会删除，仍然能正常延时投递。 此外，在queues面板中，如何查看某条具体的<em>消息</em>，也可以通过属性发现这条<em>消息</em>是延时<em>消息</em>，参考下图： ?
2.3K50发布于 2018-01-18 - 来自专栏iSharkFly
为 Confluence 6 配置发送邮件消息
https://www.cwiki.us/display/CONF6ZH/Configuring+a+Server+for+Outgoing+Mail
1.9K40发布于 2019-01-30 - 来自专栏iSharkFly
Confluence 6 自定义消息推送
推送消息是能够让你对 Confluence 站点进行了解的好方法，就算你没有在使用应用的时候，推送的消息将会在你的移动设备上显示。 点击推送的消息，可以打开移动 app 将你带到移动 app 中显示更多的内容。 Confluence app 有 3 个级别的消息通知，‘所有活动’，‘针对我的活动’，和 ‘没有’。 如果你正在使用 iOS app，选择 '自定义（Custom）'来对以后发送的消息进行配置，包括可以对下面的消息通知进行关闭： 分享（Shares） 提及（Mentions） 任务（Tasks） 你创建的页面或者博客页面的评论 有关更多 Confluence 6 服务器移动应用的使用，请参考页面使用 Confluence 服务器移动应用中的内容。 https://www.ossez.com/t/confluence-6/457
1.3K00发布于 2020-09-07 - 来自专栏马拉松程序员的专栏
Java面试考点6之消息队列
首先为了防止歧义进行说明，本课时中提到的“队列“就是指“消息队列“。 消息队列 来看消息队列的应用场景，也就是队列能解决哪些问题。 消息队列一般还提供了一写多读的能力，可以用来做消息的多播与广播。 关于队列还需要知道两个主要的消息协议。 ，也就是消息代理；右面的是消息的消费方 Consumer。 Kafka 只保证一个分区内的消息有序，不能保证一个 Topic 的不同分区之间的消息有序。 第三种方案是消息一致性方案。基本思路是将本地操作和发送消息放在一个事务中，保证本地操作和消息发送要么都成功要么都失败。下游应用订阅消息，收到消息后执行对应操作。
53020编辑于 2022-04-26 - 来自专栏mall学习教程
重磅消息：Spring 6 和 Spring Boot 3！
你可以看到Spring 6具体的发布时间线。 Spring Boot 3路线图 Spring Framework 5.3 到 6.0的关键点 排除点和变更点 可能XML配置格式会成为过去式。 jakarta.persistence(Hibernate ORM 6?)。 云原生 改进对GraalVM和Project Leyden(一个Java静态图项目)的支持。 Spring Boot 3.0 可以肯定的是Spring Boot 3基于Spring Framework 6，并且Spring Boot 3将彻底开启云原生之路。
2K40发布于 2021-09-22 - 来自专栏码农小胖哥的码农生涯
重磅消息：Spring 6 和Spring Boot 3
❝这个消息别忘记转发给其它热爱学习的小伙伴啊。 Spring Framework 5.3.x 先来看看Spring Framework 5.3.x的一些规划。 你可以看到Spring 6具体的发布时间线。 Spring Boot 3路线图 Spring Framework 5.3 到 6.0的关键点 排除点和变更点 可能XML配置格式会成为过去式。 jakarta.persistence(Hibernate ORM 6?)。 云原生 改进对GraalVM和Project Leyden(一个Java静态图项目)的支持。 Spring Boot 3.0 可以肯定的是Spring Boot 3基于Spring Framework 6，并且Spring Boot 3将彻底开启云原生之路。
2.3K30发布于 2021-09-09 - 来自专栏java跬步
事物消息的实现-RocketMQ知识体系6
首先，我们要知道什么是半事物消息和消息回查： 半事务消息： 暂不能投递的消息，发送方已经成功地将消息发送到了消息队列 RocketMQ 版服务端，但是服务端未收到生产者对该消息的二次确认，此时该消息被标记成 “暂不能投递”状态，处于该种状态下的消息即半事务消息。 消息回查： 由于网络闪断、生产者应用重启等原因，导致某条事务消息的二次确认丢失，消息队列 RocketMQ 版服务端通过扫描发现某条消息长期处于“半事务消息”时，需要主动向消息生产者询问该消息的最终状态 事务消息发送步骤如下： 发送方将半事务消息发送至消息队列 RocketMQ 版服务端。 消息队列 RocketMQ 版服务端将消息持久化成功之后，向发送方返回 Ack。 确认消息已经发送成功，此时消息为半事务消息。 发送方开始执行本地事务逻辑。
65120发布于 2021-07-29 - 来自专栏个人开发
注意：Kafka 的这 6 个场景会丢失消息！
在 Producer 端有一个 acks 配置，说明如下 ： acks=0：Producer 发送消息后不等待 Broker 的响应； acks=1：Producer 发送消息后，Leader 节点写入消息成功后给 场景五：Broker 宕机 为了提升性能，Kafka 使用 Page Cache，先将消息写入 Page Cache，采用了异步刷盘机制去把消息保存到磁盘。 看下图： 线程 1 拉取 3 条消息把 Offset 更新成 3，线程 2 把 Offset 更新成 6，线程 3 把 Offset 更新成 9。 所以，消费者并发消费很可能会造成消息丢失，如果对消息丢失很敏感，最好使用单线程来进行消费。 不过这又会带来重复消费问题，比如上面的例子，如果线程 2 消费失败了，则手动把 Offset 更新成 3，线程 3 消费成功后，再次拉取，还会拉取到 6、7、8 这三条数据。
51410编辑于 2024-04-12 - 来自专栏Rust语言学习交流
【Rust投稿】从零实现消息中间件(6)-CLIENT
功能设计 client实现功能相对比较单一,就是能够向服务器pub消息,然后就会说订阅消息,订阅的主题收到消息以后能够得到通知.因此总结起来就是下面三个功能: 提供pub接口 提供sub接口 处理sub 后收到的消息 数据结构定义 提供给用户的接口是上面的三个, 为了实现这三个接口,client一定要有的就是writer以及handler. pub async fn connect(addr: &str) -> std::io::Result<Client> {} 接口-pub_message 向服务器发布一条pub消息 pub async ,然后等待服务器推送相关消息. ,解析,以及将消息派发给合适的handler.
94510发布于 2020-03-11 - 来自专栏stark张宇
消息队列中间件 - 详解RabbitMQ6种模式
RabbitMQ 6种工作模式对RabbitMQ 6种工作模式(简单模式、工作模式、订阅模式、路由模式、主题模式、RPC模式)进行场景和参数进行讲解，PHP代码作为实例。 \n";# 关闭信道和链接$channel->close();$connection->close();6种模式1.简单模式图片简单模式是最简单的使用方式，P代表生产者，C代表消费者，红色的代表队列，执行过程生产者发送消息到队列 生产者把消息发送给交换机，交换机把消息发送给和它绑定的队列，让消费者来消费，需要强调的是绑定的队列获得的消息是一模一样的，订阅模式就是让所有的消费者获得相同的消息。 订阅模式和路由模式的区别，订阅模式无条件的把消息发送给所有的消费者，每一个消费者收到的消息都是一样的，而路由模式对消息进行筛选发送给对应的消费者队列。 6.RPC模式RabbitMQ的RPC模式，支持生产者和消费者不在同一个系统中，即允许远程调用的情况。通常，消费者作为服务端，放置在远程的系统中，提供接口，生产者调用接口，并发送消息。
47243编辑于 2023-05-07 - 来自专栏RabbitMQ实战
AMQP-RabbitMQ6RPC模式关注消息处理结果
6. RPC But what if we need to run a function on a remote computer and wait for the result? 大概意思是说，上面几种模式都是生产者将消息发送到Rabbitmq，然后就不管了，也不管是否有消费者进行了消费，也不管消费的结果是怎样的。上面几种场景已经可以满足大多数需求。
66230发布于 2020-06-29 - 来自专栏kafka专栏
6.【kafka运维】删除Topic消息+查看Broker磁盘信息
文章目录 1.删除指定分区的消息kafka-delete-records.sh 2. 查看Broker磁盘信息kafka-log-dirs.sh More 日常运维 、问题排查 怎么能够少了滴滴开源的 滴滴开源LogiKM一站式Kafka监控与管控平台 1.删除指定分区的消息kafka-delete-records.sh 删除指定topic的某个分区的消息删除至offset为1024 先配置json文件offset-json-file.json {"partitions": [{"topic": "test1", "partition bootstrap-server 172.23.250.249:9090 --offset-json-file config/offset-json-file.json 验证 通过 LogIKM 查看发送的消息 从这里可以看出来,配置"offset": 1024 的意思是从最开始的地方删除消息到 1024的offset; 是从最前面开始删除的 2.
1.2K20发布于 2021-08-09 - 来自专栏浩Coding
微信个人公众号开发--(6)用户语音消息智能识别
今天经过朋友Mr.丁的提示,发现微信有自动识别语音消息,并将识别后的文本返回的功能,这正好省去我们调用讯飞语音识别接口了,还是无限免费使用的,好了,不多嘚嘚,看正文: 先在微信后台页面->开发- t=resource/res_main&id=mp1421140453 开通语音识别后，用户每次发送语音给公众号时，微信会在推送的语音消息XML数据包中，增加一个Recongnition字段（注：由于客户端缓存 所以我们只需要只需要在识别是语音消息后,增加一个字段存储语音识别文本即可,代码如下: if (MessageUtil.MESSAGE_VOICE.equals(msgType)) {//语音识别 String recognition = map.get("Recognition"); // 智能语音识别消息 message = wxFunction(toUserName
2.3K51发布于 2019-07-02 - 来自专栏即时通信IM
好消息！腾讯云即时通信IM支持IPv6啦！
在我们打开某些APP的时候会看到首页的下方会出现一行字： xxxx支持IPv6网络 ? 这究竟是什么意思？ 今天，就给大家好好聊聊我们互联网新朋友——IPv6。 举个例子：网聊的时候，表面上小红给小明发了一条消息。 3、无状态自动配置：一个IPv6设备根据本身分配一个独特link-local IPv6的地址 4、独立或不独立于提供商的编址 IPv6对腾讯云即时通信IM有什么影响？ 腾讯云在自主研发针对IPv6协议的DDoS防护平台已经完成开发。目前各大业务都陆续支持IPv6网络。 安全性更高 IPv6具有更高的安全性。在使用IPv6网络中用户可以对网络层的数据进行加密并对IP报文进行校验，在IPv6中的加密与鉴别选项提供了分组的保密性与完整性。极大的增强了网络的安全性。
5.6K20发布于 2020-06-19 - 来自专栏黄啊码【CSDN同名】
【黄啊码】TP6消息推送、队列的使用（thinkphp-queue，可实现小程序消息订阅延迟推送）
topthink/think-queue - PackagistThe ThinkPHP6 Queue Package https://packagist.org/packages/topthink/think-queue php /** * 消息队列配置 * 内置驱动：redis、database、topthink、sync */ use think\Env; return [ //sync驱动表示取消消息队列还原为同步执行 //"expire"=>60,//任务过期时间，单位为秒，禁用为null //"default"=>"default",//默认队列名称 //"table"=>"jobs",//存储消息的表明 [ 'id' => uniqid(), 'time' => time(), ]; //将该任务推送到消息队列 } /** * @Title: checkDatabaseToSeeIfJobNeedToBeDone * @Description: todo(有些消息在到达消费者时
2.6K40编辑于 2022-01-10 - 来自专栏IT大咖说
RocketMQ源码详解：事务消息、批量消息、延迟消息
◆ 概述 在上文中，我们讨论了消费者对于消息拉取的实现，对于 这个黑盒的心脏部分，我们顺着消息的发送流程已经将其剖析了大半部分。本章我们不妨乘胜追击，接着讨论各种不同的消息的原理与实现。 ◆ 事务消息 ◆ 概念 RocketMQ 中的事务消息功能，实际上是 分布式事务中的本地事务表 的实现，只不过，在这里用消息中间件来代替了数据库，同时也帮我们做好了回查的操作。 ◆ 事务流程 客户端发送 half 消息 吐槽一下为什么要叫半消息(half message)，叫 prepare 消息不是更直观吗 Broker 将 half 消息持久化 客户端根据事务执行结果，发送 ，来标记可以被移除的 half 消息（op 消息的存在代表对应事务的结束） /** * 读取op消息，解析op消息，填充removeMap * * @param removeMap 要删除的半消息，key ◆ 批量消息 ◆ 概念 在消息队列中，批量消息也是一个重要的部分，将消息压缩在一起发送不仅可以减少带宽的消耗，还能节省头部占用的空间。
1.6K20发布于 2021-11-26 - 来自专栏散尽浮华
centos6下ActiveMQ+Zookeeper消息中间件集群部署记录
由于最近一个项目并发请求压力比较大，所以考虑改进架构，引入消息中间件集群作为一个缓冲消息队列，具体需求： 1）将大量的WebService请求报文发送到mq集群之中，并保持消息先后顺序 2）保证每个消息的可靠性 172.16.51.183 软件版本：activemq-5.11.1、zookeeper-3.4.11 好了，废话不多说，下面记录下部署过程： 由于最近一个项目并发请求压力比较大，所以考虑改进架构，引入消息中间件集群作为一个缓冲消息队列 ，具体需求： 1）将大量的WebService请求报文发送到mq集群之中，并保持消息先后顺序 2）保证每个消息的可靠性 3）维护MQ服务器的可扩展性 综合考虑，决定使用Apache的activemq， activemq是Apache出品，最流行的，能力强劲的开源消息总线。 需要在activemq.xml文件中的</shutdownHooks>下新增下面内容，用于消息连接身份认证的用户名和密码。
1K90发布于 2018-01-23 - 来自专栏凯哥Java
RabbitMQ消息中间件技术精讲6 几种交换机总结
会把消息路由到那些bingding key与routing key完全匹配的队列中。Rabbit mq默认的路由就是这种。 Topic交换机与direct交换机有点类似：需要使用指定的key发送消息将被发送到所有使用匹配绑定key的队列。 不同点：topic exchange支持模糊匹配。 一句话：所有符合routingkey（此中状态下的key可以是一个表达式）的routingkey所有bingd的队列都可以收到消息。 当生产者P发送a.orange.b消息的时候，会被Q1队列接收。规则见上。 Fanout Exchange:广播模式 此种模式下，会把所有发送到当前交换机的消息全部路由到所有与当前交换机绑定的队列中去。
52950发布于 2019-07-16 - 来自专栏高级开发进阶
【JavaP6大纲】分布式事务篇：MQ 事务消息
MQ 事务消息？ MQ 事务消息 有一些第三方的MQ是支持事务消息的，比如RocketMQ，他们支持事务消息的方式也是类似于采用的二阶段提交，但是市面上一些主流的MQ都是不支持事务消息的，比如 RabbitMQ 和 Kafka 第一阶段Prepared消息，会拿到消息的地址。第二阶段执行本地事务，第三阶段通过第一阶段拿到的地址去访问消息，并修改状态。也就是说在业务方法内要想消息队列提交两次请求，一次发送消息和一次确认消息。 如果确认消息发送失败了RocketMQ会定期扫描消息集群中的事务消息，这时候发现了Prepared消息，它会向消息发送者确认，所以生产方需要实现一个check接口，RocketMQ会根据发送端设置的策略来决定是回滚还是继续发送确认消息 这样就保证了消息发送与本地事务同时成功或同时失败。 优点： 实现了最终一致性，不需要依赖本地数据库事务。 缺点： 实现难度大，主流MQ不支持，RocketMQ事务消息部分代码也未开源。
75140发布于 2021-04-08
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号