- 综合排序
- 最热优先
- 最新优先
- 来自专栏Flutter入门到实战
消息传输模型的思考
一、消息传输模型 从消息传输模型上，大致可以抽象为以下几种： （1）点对点模型（Point-to-point） 基础模型中，只有一个发送者、一个接收者和一个分布式队列。 在P2P模型中，有几个关键术语：消息队列(Queue)、发送者(Sender)、接收者(Receiver)。每个消息都被发送到一个特定的队列，接收者从队列中获取消息。 每个消息只有一个消费者(Consumer)（即一旦被消费，消息就不再在消息队列中） 发送者和接收者之间在时间上没有依赖性，也就是说当发送者发送了消息之后，不管接收者有没有正在运行，它不会影响到消息被发送到队列 接收者在成功接收消息之后需向队列应答成功。 如果你希望发送的每个消息都应该被成功处理的话，那么你需要P2P模型。 其中，Twitter的Storm 0.9.0以前的版本中默认使用ZeroMQ作为数据流的传输（Storm从0.9版本开始同时支持ZeroMQ和Netty作为传输模块）。
1.4K30发布于 2019-07-23 - 来自专栏笔记本
RabbitMQ的消息可靠传输
RabbitMQ的消息可靠传输AMQP协议架构RabbitMQ是基于AMQP协议实现的消息中间件，AMQP有一套自己的架构，RabbitMQ的架构也基于此。如图所示就是AMQP协议的基础架构。 生产者生产者就是我们发送消息的角色，是消息的发送方，负责把需要被处理的消息发送到下游——交换机。 生产者（confirm消息确认机制）生产者在发送消息前，会为消息指定要发送的交换机名称和路由键。 消息持久化机制（RabbitMQ）MQ收到消息后会将消息保存到磁盘中，保证RabbitMQ服务器在宕机或者重启的时候，消息不会丢失。 注意如果只将队列持久化但是消息没有持久化，那么消息是会丢失的；同时，只将消息持久化，队列没有持久化的话，消息依旧会丢失，因为消息是存储在对应队列中的。
29021编辑于 2025-07-08 - 来自专栏IT当时语_青山师_JAVA技术栈
消息队列如何保证消息可靠性传输
消息队列如何保证消息可靠性传输 随着互联网的发展，消息队列已经成为了系统设计中不可或缺的一部分。它可以实现系统之间的异步通信和解耦，提高整体系统的可靠性和性能。 但是，由于网络的不可靠性和系统崩溃等原因，消息在传输过程中可能会出现丢失和重复等问题。为了解决这些问题，消息队列需要采用一系列机制来保证消息的可靠性传输。 可靠性传输机制 为了保证消息的可靠性传输，常见的机制包括： 持久化存储 在消息发送之前，消息队列需要将消息进行持久化存储，确保消息在遭遇意外情况时也不会丢失。 消息确认机制 在消息发送完成后，发送方需要接收到接收方的确认消息，才能认为消息发送成功。如果发送方没有接收到确认消息，则需要对消息进行重发，以保证消息的可靠传输。 总结 以上就是消息队列如何保证消息可靠性传输的介绍。
90510编辑于 2023-05-05 - 来自专栏向治洪
实时消息传输协议（RTMP）详解
RTMP块流被设计用来传输实时消息协议，它可以使用任何协议来发送消息流。每个消息都包含时间戳和有效类型标识。 C1和S1格式 C1和S1包长度为1536字节，包含以下字段: 0 1 2 3 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 C2和S2格式 C2和S2包长度为1536字节，作为C1和S1的回应，包含以下字段: 0 1 2 3 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 Message Type ID为8，9的消息分别用于传输音频和视频数据。Message Type ID为15-20的消息用于发送AMF编码的命令，负责用户与服务器之间的交互，比如播放，暂停等等。 消息的报文结构如下图所示。 ? 消息块 在网络上传输数据时，消息需要被拆分成较小的数据块，才适合在相应的网络环境上传输。RTMP协议中规定，消息在网络上传输时被拆分成消息块（Chunk）。
13.5K52发布于 2018-02-06 - 来自专栏JavaEdge
消息队列面试解析 - 传输协议
应用程序之间要想互相通信，一起配合来实现业务功能，还需传输协议支持。 传输协议就是应用程序之间对话的语言。 在数据传输过程，无论你定义什么字符作为分隔符，理论上都有可能会在传输的数据中出现。 双工通信，就是说不管是客户端还是服务端建立好链接之后，双方都可以基于该socket进行收发消息就好了，而不是说服务器只能accept到message之后再做一些处理。 https://github.com/WangYangA9/netty-FullDuplex-example https://sourcegraph.com/github.com/swgithub1006 那接到消息的一方，该如何分辨序列号的长度大小，做到区分序列号和内容前的数据长度信息？ 开头是数据长度，序号也是数据的一部分，所以应该在长度之后。
59010发布于 2021-02-22 - 来自专栏网络
消息传输的设计方式（上）
Apache Pulsar Pulsar是分布式订阅发布消息传输系统，最早有由Yahoo公司开发的，并在2016年正式开源。 Pulsar提供了灵活消息传输、多租户、跨地理位置数据复制等特性。 Pulsar的创始人Joe和Matteo等人认为需求是Pulsar项目启动的原因，如果应用程序提供实时服务，需要保证平均5ms以内的发布延迟，99%的请求不会超过15ms的延迟，同时满足分类、强持久性以及传输保证等特征的消息传输系统 命名空间是Pulsar集群的最基本管理单元，在命名空间级别，你可以设置权限、调优复制策略、管理跨集群的消息数据复制、控制消息过期，以及其他关键操作。同一个命名空间里的主题共享相同的配置。 Apache Pulsar Pulsar是分布式订阅发布消息传输系统，最早有由Yahoo公司开发的，并在2016年正式开源。 Pulsar提供了灵活消息传输、多租户、跨地理位置数据复制等特性。 Pulsar的创始人Joe和Matteo等人认为需求是Pulsar项目启动的原因，如果应用程序提供实时服务，需要保证平均5ms以内的发布延迟，99%的请求不会超过15ms的延迟，同时满足分类、强持久性以及传输保证等特征的消息传输系统
1.2K80发布于 2018-01-09 - 来自专栏码出code
SpringBoot 整合 RabbitMQ 实现消息可靠传输
消息的可靠传输是面试必问的问题之一，保证消息的可靠传输主要在生产端开启 comfirm 模式，RabbitMQ 开启持久化，消费端关闭自动 ack 模式。 消息丢失分析 一条消息的从生产到消费，消息丢失可能发生在以下几个阶段： 生产端丢失：生产者无法传输到 RabbitMQ 存储端丢失：RabbitMQ 存储自身挂了 消费端丢失：存储由于网络问题，无法发送到消费端 ，或者消费挂了，无法发送正常消费 RabbitMQ 从生产端、储存端、消费端都对可靠性传输做很好的支持。 生产阶段 生产阶段通过请求确认机制，来确保消息的可靠传输。 消费端 消费端默认开始 ack 自动确认模式，当队列消息被消费者接收，不管有没有被消费端消息，都自动删除队列中的消息。
57230编辑于 2023-02-26 - 来自专栏架构师
图解：消息传输的架构模式
从概念上讲，一条消息是一个发送方与一个或多个接收方之间的一次信息交换。自从大型机问世以来，消息交换一直是计算机编程和架构设计的重要组成部分。 多年来，消息传输的实践已经发展成多种消息传输模式。 1消息交换架构 本节描述与在发送方和接收方之间传输消息的机制相关的消息传输模式。 2路由 本节列出的消息传输模式描述了在发送方和接收方之间路由消息的各种方法。发布 - 订阅、扇出和流模式专注于数据传输的架构，而单播、广播、多播和任播模式则专注于路由。 通常来说，任播模式用于根据地理位置的接近程度将消息从发送方路由到接收方，如下图 9 所示。 ? 内容交付网络通常使用任播模式 内容交付网络（CDN）是一种使用任播模式的技术。 用通用名称封装消息传输模式的好处在于，它允许架构师和开发人员以相同的方式讨论同一件事。对消息传输模式使用常规名称可以节省时间。
73520发布于 2021-06-10 - 来自专栏架构之家
图解：消息传输的架构模式
从概念上讲，一条消息是一个发送方与一个或多个接收方之间的一次信息交换。自从大型机问世以来，消息交换一直是计算机编程和架构设计的重要组成部分。 多年来，消息传输的实践已经发展成多种消息传输模式。 消息交换架构 本节描述与在发送方和接收方之间传输消息的机制相关的消息传输模式。 发布-订阅 发布-订阅（Pub-Sub）模式指的是发布者将消息发送到消息代理（broker）上的主题（topic）。 路由 本节列出的消息传输模式描述了在发送方和接收方之间路由消息的各种方法。发布-订阅、扇出和流模式专注于数据传输的架构，而单播、广播、多播和任播模式则专注于路由。 通常来说，任播模式用于根据地理位置的接近程度将消息从发送方路由到接收方，如下图 9 所示。 内容交付网络通常使用任播模式 内容交付网络（CDN）是一种使用任播模式的技术。 用通用名称封装消息传输模式的好处在于，它允许架构师和开发人员以相同的方式讨论同一件事。对消息传输模式使用常规名称可以节省时间。
80720编辑于 2022-07-12 - 来自专栏文件传输
大件传输的9种方法
4.镭速 有特定的企业，需要进行点对点的传输方式，而且多部门的跨区域协作，针对于这一点，镭速传输支持根据不同的传输发起方提供多种模式传输方式。支持点对点、多点互传，数据云传输，一对多数据分发等模式。 镭速传输提供一站式文件传输加速解决方案，旨在为IT、影视、生物基因、制造业等众多行业客户实现高性能、安全、稳定的数据传输加速服务。 传统文件传输方式（如FTP/HTTP/CIFS）在传输速度、传输安全、系统管控等多个方面存在问题，而镭速文件传输解决方案通过自主研发、技术创新，可满足客户在文件传输加速、传输安全、可管可控等全方位的需求 Filemail相比较传统的FTP传输方式，数据传输安全性更高，不会受高延迟网络的影响；相比较WeTransfer，Filemail会对发送的文件进行病毒扫描，在传输文件过程中进行完整性检查，免费用户可以使用的传输容量也比它大 9.SendTransfer SendTransfer是一项免费的空间服务，支持最大10GB的单一文件。用户不需要注册和登录就可以使用，而且对下载和流量没有限制。
2.2K30编辑于 2023-02-15 - 来自专栏JavaEdge
消息的可靠性传输，如何处理消息丢失问题？
用MQ时，要注意消息数据： 不能多，牵涉重复消费处理和幂等性问题 不能少，消息不能搞丢呀 若这是用MQ传递非常核心的消息，如计费系统，就是很重的业务，操作很耗时，设计上经常将计费做成异步化，就是用MQ。 若RabbitMQ未能处理该消息，就会回调你一个nack接口，告诉你这个消息接收失败，你可以重试。可结合该机制，自己在内存里维护每个消息id的状态，若超过一定时间还没接收到该消息的回调，你就能重发。 在 RocketMQ 中，事务消息可以保证消息零丢失。 4 总结 本文分别从生产者、MQ 自身、消费者介绍了导致消息丢失的原因，消息丢失问题是一个比较常见但又必须解决的问题。 不同的 MQ 如何解决消息丢失问题的。 Confirm 模式避免消息丢失；Kafka 则配置所有 follower 同步成功才给生产者响应推送消息成功；RocketMQ 则使用事务消息来保证消息的零丢失，针对不同的异常情况还提供了补偿机制进行处理
1.5K20编辑于 2022-11-30 - 来自专栏码农编程进阶笔记
基于极光推送实现消息传输(PHP版)
一、如何用php实现APP消息推送 现在有很多的消息推送厂商，比如阿里云的消息推送，极光推送，融云的消息推送。 他们的原理都是把sdk内置在app里面，达到消息推送的目的，通过一张图来了解一下，看不懂的也不要紧，理解大概的过程就行。
1.3K30编辑于 2022-04-08 - 来自专栏Java程序猿部落
如何保证消息的可靠性传输？
面试题 如何保证消息的可靠性传输？或者说，如何处理消息丢失的问题？ 如果说你这个是用 MQ 来传递非常核心的消息，比如说计费、扣费的一些消息，那必须确保这个 MQ 传递过程中绝对不会把计费消息给弄丢。 中，RabbitMQ 会给你回传一个 ack 消息，告诉你说这个消息 ok 了。 如果 RabbitMQ 没能处理这个消息，会回调你的一个 nack 接口，告诉你这个消息接收失败，你可以重试。 第二个是发送消息的时候将消息的 deliveryMode 设置为 2 就是将消息设置为持久化的，此时 RabbitMQ 就会将消息持久化到磁盘上去。
1.3K10发布于 2019-05-31 - 来自专栏悠扬前奏的博客
Kafka-9.设计-消息分发语义
显然，有多个可能的消息专题保证可以提供： 最多一次——消息可能会丢失，但是永远不会重复传递 至少一次——消息永远不会丢失，但是可能会被重新传递 恰好一次——这是人们真正想要的，每条消息传递一次 值得注意的是 ，这会分解成两个问题：发布消息的持久性保证以及消费消息时的保证。 在发布消息时，我们有一个消息被“提交”到日志的概念。一旦提交已经发布的消息，只要把消息复制到分区的broker保持“活动”，它就不会丢失。 如果生产者尝试发布消息并遇到网络错误，则无法确定在提交消息之前或者之后发生了此错误。这类似于使用自动生成的密钥插入数据库表的语义。 为了实现这个目的，broker为每个生产者分配一个ID，并使用生产者发送的序列号和每条消息对每条消息进行重复数据删除。
62530发布于 2019-06-15 - 来自专栏RTSP/RTMP直播相关
GBT 28181-2016多响应消息传输探究
我们在实现Android平台GB28181设备接入模块的时候，有遇到发送多条记录的情况，本文主要探讨下GB28181多响应传输。 为了保证多条响应、通知消息传输的稳定可靠，多条响应、通知消息发送时宜采用串行发送方式，记录发送方需收到上一条SIP Message消息的SIP响应后再进行后续发送处理。 待发送记录条数达到百条级别时,为缩短传输时间宜在每条响应消息中携带多条记录，每条响应消息携带记录上限为10000条。 目录查询应答命令应支持多响应消息传输的要求。 源设备包括SIP客户端、网关或联网系统,目标设备包括SIP设备、网关或联网系统。 设备视音频文件检索文件检索主要用区域、设备、录像时间段、录像地点、录像内容为条件进行查询,用 Message消息发送检索请求和返回查询结果,传送结果的 Message消息可以发送多条,应支持多响应消息传输的要求
58500编辑于 2022-10-26 - 来自专栏码出code
如何保证消息队列的可靠性传输？
消息丢失分成三种情况，可能出现生产者、RabbitMQ、消费者。 生产者丢失数据 首先要确保写入 RabbitMQ 的消息别丢，消息队列通过请求确认机制，保证消息的可靠传输。 生产开启 comfirm 模式，在生产者开启 comfirm 模式之后，每次发送消息都会分配一个唯一的id。 如果写入了 RabbitMQ 中，RabbitMQ 会回传一个 ack 消息 如果没能写入 RabbitMQ，会回调一个 nack 接口， 可以重新发送消息 一般在生产者这块避免数据丢失，都是用 confirm 还有一种少见的情况，就是RabbitMQ还没将消息持久化，自己就挂了。这种情况需要生产者那边的确认机制结合起来。只有消息被持久化到磁盘以后，才会回传 ack 消息。 每次在消费端处理后，再在程序里做 ack 确认，这样的话，如果没有处理完，就没有 ack 确认，那 RabbitMQ 就认为你还没有处理完，这个时候 RabbitMQ 会重新发送消息给消费者。
49610编辑于 2023-02-25 - 来自专栏用户2442861的专栏
实时消息传输协议 RTMP(Real Time Messaging Protocol)
以下是维基百科原文： 实时消息传输协议(RTMP)最初是由 Macromedia 为互联网上 Flash player 和服务器之间传输音频、视频以及数据流而开发的一个私有协议。 为了能够顺利地传输流，并且传递尽可能多的信息，RTMP 对流进行分段，客户端和服务器可以对分段长度进行协商，尽管有时分段长度是不变的：对于音频数据默认分段长度是 64 字节，视频数据和大部分其他数据类型默认分段长度是为 块消息报头包含 meta-data 信息，比如消息大小(以字节为单位)，Timestamp 以及消息类型。 字节 #8 (0x14) = 消息类型 ID - 0x14 (20) 定义了一个 AMF0 编码的命令消息。 字节 #9-12 (0x00000000) = 消息流 ID。 连接建立以后，媒体由封装为 FLV tag 内容的 RTMP 消息对类型 8 和 类型 9 的音频和视频交叠发送。
3.1K10发布于 2018-09-20 - 来自专栏IT运维技术圈
大文件传输的9种方法
4.镭速 有特定的企业，需要进行点对点的传输方式，而且多部门的跨区域协作，针对于这一点，镭速传输支持根据不同的传输发起方提供多种模式传输方式。 镭速传输提供一站式文件传输加速解决方案，旨在为IT、影视、生物基因、制造业等众多行业客户实现高性能、安全、稳定的数据传输加速服务。 传统文件传输方式（如FTP/HTTP/CIFS）在传输速度、传输安全、系统管控等多个方面存在问题，而镭速文件传输解决方案通过自主研发、技术创新，可满足客户在文件传输加速、传输安全、可管可控等全方位的需求 Filemail相比较传统的FTP传输方式，数据传输安全性更高，不会受高延迟网络的影响；相比较WeTransfer，Filemail会对发送的文件进行病毒扫描，在传输文件过程中进行完整性检查，免费用户可以使用的传输容量也比它大 9.SendTransfer SendTransfer是一项免费的空间服务，支持最大10GB的单一文件。用户不需要注册和登录就可以使用，而且对下载和流量没有限制。
4.7K30编辑于 2023-08-10 - 来自专栏浮躁的喧嚣
对象、消息、运行期--9：类族模式
这种模式最大的好处就是，可以隐藏抽象基类背后的复杂细节，使用者只需调用基类简单的方法就可以返回不同的子类实例。比如NSArray、NSDictionary、UIButton等
26310编辑于 2023-11-22 - 来自专栏大内老A
WCF如何克服HTTP传输协议的局限提供对不同消息传输模式的实现
消息会被WCF的信道层发送到传输层，并通过相应的传输协议发送到目的地。对于TCP协议来说，其本身就能提供一个双工通道，所以能够对以上三种MEP原生的支持。 One-Way模式基于从一个源到一个或者多个目的地的单向消息传输。如右图所示，在One-Way模式下，消息的发送方将消息发送到接收方，并不希望收到对象的回复。 那么，当我们采用基于HTTP的绑定（BasicHttpBinding、WSHttpBinding和WS2007HttpBinding等）调用One-Way服务操作的时候，传输层（HTTP Transport 主题发布的时候，发布方提取当前主题的所有订阅方，对它们进行消息广播。 ? 消息的交换依赖于网络传递，不同的网络传输协议对双工通信具有不同的支持方式。 从消息交换的角度讲，客户端调用服务端和服务端对客户端进行回调，本质上是一样的。所以，从HTTP传输层看，真正的消息交换方式如左图所示。
1.4K70发布于 2018-01-16
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号