当我们采用两阶段提交的方案时，而不是单台服务器转发，那么当多个客户端同时企图获取大部分服务器的锁的时候，会发生什么情况呢？客户端是否必须释放它们所有获得的锁，以避免死锁。又或者客户端获取部分锁之后挂掉了呢？
一诺千金。古人有云，“一言既出,驷马难追”，一句话说出了口，就是套上四匹骏马拉的车也难追。可见对说出口的话，是多么重视。 可是，人总有说错话的时候，比如： 为了解决手残星人的烦恼，微信在5.3.1.16版本中上线了“微信撤回”的功能，对于发出2分钟以内的信息提供撤回选项： 用户长按发出的消息(包括图片)，在多选中选择撤回。 那么问题来了， 为什么发出去的消息可以轻松撤回 在韩剧《来自星星的你》中，为了不让千颂伊看到下意识发出的“表白”短信，wuli都教授可是不惜动用时空穿梭和空间静止两大“杀器”。
离上次更新文章已有快5个月，我还是有点懒。但我们系统的研发并没有因此停下来。下面先简单介绍下MdbCluster最近的一些进展。
熟悉TCP变成的可以知道，无论是客户端还是服务端，但我们读取或者发送消息的时候，都需要考虑TCP底层粘包/拆包机制，下面我们先看一下TCP 粘包/拆包和基础知识，然后模拟一个没有考虑TCP粘包/拆包导致功能异常的案例，最后，通过正确的例程来谈谈Netty是如何实现的。
32位序号：随机生成，唯一标识当前报文的序号是多少，seq表示 32位确认序号：对上一条发送的信息进行一个消息的确认，ack表示 ACK：确认标志位，一位，只能表示0/1。 SYN：1:发起一个新的连接 FIN：1:结束一个连接
参考学习： https://juejin.im/post/5a14e9edf265da4312808d86 https://molunerfinn.com/observer-vs-pubsub-pattern https://juejin.im/post/5bb1bb616fb9a05d2b6dccfa https://juejin.im/post/57de12355bbb50005e648bd8
对于上面的例子，天气预报需要用户自己付费订阅、群聊需要先进群、在家看报需要联系报社订阅报纸。这里就能看出来。这种关系是一个一对多的关系。被观察者是同一个，而观察者却可以是很多个不同的对象。还有就是观察者需要自己主动的去找被观察者“提前”说明好，“一旦有消息，请通知我一声”。所有这里可以抽象出来几个角色和动作。
精确一次处理语义(exactly onece semantic–EOS)，Kafka的EOS主要体现在3个方面：
很长一段时间以来，我们一直听说在同步网络中,实现50%容错的共识是有可能的。在同步网络中，任何可信节点广播的消息都可以保证在某个已知时间段内被所有其它可信节点接收。
尽管几乎没有人理解电磁场理论，但我们都能很好地使用手机。如果必须了解波传播的细节，相信几乎没有人会使用电话。很多时候，我们虽然不了解一些原理，但是，我们仍然可以很好的利用它们。比如很多基本的网络规则。
当我们思考我们的日常行为时，我们常常没有意识到我们每天自动做的行为的百分比有多大。原因是:我们被那些与我们的需求紧密相连的无意识行为所“吸引”。根据《The Power of Habit》一书的作者Charles Duhigg的说法，大约40%到45%的日常行为是无意识的，因此，我们称之为习惯。虽然我们可能感觉像是在做决定，但我们并没有有意识地去思考。
根据RabbitMQ的工作模式，一条消息从生产者发出，到消费者消费，需要经历以下4个步骤：
微信用于个人社交，产品设计上，在线状态，强制已读回执都有可能暴露个人隐私，故微信并无相关功能。
本文为 WebSocket 协议的第六章，本文翻译的主要内容为 WebSocket 消息发送与接收相关内容。
在斯坦福大学, 乔布斯做了一场我认为他最精彩的演讲之一 (另一场可能是iphone的问世发布会)。他讲了第一个故事 "connecting the dots"
我们平时在使用即时通讯应用时候，每当发出一条聊天消息，都希望对方尽快看到，并尽快回复，但对方到底有没有真的看到？我却并不知道。
有一天，卡尔维护的购买系统发生了一个奇怪的异常，从日志里看到，购买后的任务处理竟然先于购买任务执行了。“不可能啊，按照代码的顺序，一定是先执行购买流程，再发送消息到kafka，最后消费端接收到消息后执行购买后的一些善后任务。从A到B到C，顺序清清楚楚。” 于是，他请教了马克，马克眯着眼睛细看了一会，道:"问题是不是出在这段@Transaction注解上？"
这个系列就以「消息管理平台」来打个样吧，这是我维护近一年的系统了。这篇文章可以带你全面认识「消息管理平台」是怎么设计和实现的，有兴趣的同学欢迎在评论区下留言和交流。
XMPP是一个用于通讯和表示的开放标准协议。从本质上讲，它是一个允许实体交换信息和进行聊天的协议。
发布者发布消息时，如果 Retained 标记被设置为 true，则该消息即是 MQTT 中的保留消息（Retained Message）。MQTT 服务器会为每个主题存储最新一条保留消息，以方便消息发布后才上线的客户端在订阅主题时仍可以接收到该消息。
RabbitMq是我们在开发过程中经常会使用的一种消息队列。今天我们来研究研究rabbitMq的使用。
即对于HTTP协议来说，服务端给一次响应后整个请求就结束了，这是HTTP请求最大的特点，也是由于这个特点，HTTP请求无法做到的是服务端向客户端主动推送数据。
微信（WeChat） 是腾讯公司于2011年1月21日推出的一个为智能终端提供即时通讯服务的免费应用程序，由张小龙所带领的腾讯广州研发中心产品团队打造 。在互联网飞速发展的下、民众的需求下，微信已经更新到6.6.6版本，全民微信时代。村口的张大妈，家里的老父亲都知道怎么使用微信。
SCTP (Stream Control Transmission Protocol)是一种传输协议，在TCP/IP协议栈中所处的位置和TCP、UDP类似，兼有TCP/UDP两者特征。
近日，工信部发布的《2018年上半年通信业经济运行情况》显示，上半年我国移动短信业务量同比增长8.8%；移动短信业务收入完成195亿元，同比增长5.7%。业内人士纷纷表示，短信业务焕发了“第二春”。
在生产环境中由于一些不明原因，导致 rabbitmq 重启，在 RabbitMQ 重启期间生产者消息投递失败， 导致消息丢失，需要手动处理和恢复。于是，我们开始思考，如何才能进行 RabbitMQ 的消息可靠投递呢？ 特别是在这样比较极端的情况，RabbitMQ 集群不可用的时候，无法投递的消息该如何处理呢:
这个和日志复制的机制有关系。首先对于选举，PK的条件不是拼这两个索引值的大小，PK的是最后一条日志的任期号和日志的长度。Leader当选后进行第一次日志复制时，会和Follower进行若干次日志的匹配过程，最终可以得到Leader和各自Follower的日志匹配的matchIndex值。处于majority节点列表的matchIndex的最小值就是当前Leader的commitIndex。所以commitIndex值是完全可以动态计算出来的。 如果所有的日志都保留不截断的话，服务器重启时applyIndex应该等于零。然后重放一下所有的已经提交的日子就可以得到当前的状态机。如果日志截断有快照的话，applyIndex应该正好是日志序列的头部位置，这个位置一般是存储在快照元信息里面的，它是持久化在磁盘中的。
还有个背景是前段时间刚哄着妞去民政局领了证，五一刚走了家乡的定亲仪式。不能让妞以为我这样想：“到手后的媳妇就不需要再用心宠着了”。
首先生产者线程main生成消息后调用send方法，然后会经过拦截器、序列化器、分区器（Partition），分区器会对消息进行分区放入不同的本地队列，本地队列保存在计算机的内存中，每个队列32m，每16k数据形成一批消息；
写在前面的话 本文所介绍的漏洞存在于一款当前热门的约会应用之中，在编写这篇文章时，我也已经对截图中可能会涉及到的App、组织以及用户名称进行了处理，因为我不想损害相关方的切身利益。 本文所涉及到的应用程序来源于一家创业公司，而且这家公司的经营状况也非常好。我出于教育目的编写了这篇文章，希望能够为安全社区贡献自己的绵薄之力。需要注意的是，本文所介绍的漏洞已经披露给了相关厂商，这些漏洞现已得到修复。 故事开始 我当时发现了一款热门的约会App，这款App拥有超过一百万的用户量。鉴于这款App受欢迎程度如此之
Work Queues，也被称为（Task Queues）任务模型。当消息处理比较耗时的时候，可能生产消息的速度会远远大于消息的消费速度。长此以往，消息就会堆积越来越多，无法及时处理。此时就可以使用 work 模型：让多个消费者绑定到一个队列，共同消费队列中的消息。队列中的消息一旦消费，就会消失，因此任务是不会被重复执行的。
集群(cluster)是Redis提供的分布式数据库解决方案，集群通过分片(sharding)来进行数据共享，并提供数据复制(replication)和故障转移(failover)等功能。下面介绍下Cluster的执行流程。
准备好了解物联网世界了吗？这个世界可能是由通过电子学、传感器和软件嵌入的联网的设备和其他物体组成的，物联网的世界是由健身追踪器、应用、汽车、路由器以及无数个其他连接的物体组成的。系好安全带我们开始进入物联网世界之旅吧。
本章我们将研究 Broadcast protocols广播协议（也称为multicast protocols 组播协议），即向多个接收者传递同一条信息的算法。正如我们将在第5讲中看到的那样，这些协议可以用来构成更高级分布式算法。在实践中，几种不同的广播协议都有采用，它们的主要区别在于传递消息的顺序order。正如我们在上一讲中看到的，顺序的概念与时钟和时间密切相关。因此，我们将在本章开始时，更深入地研究时钟如何帮助我们跟踪分布式系统中的顺序。
作者 | Chris Lukic 译者 | 王强 策划 | 万佳 过去几个月里，我一直在对付一个流行健身品牌的 API，最后发现自己陷入了一种卡夫卡式的噩梦。程序员都喜欢挑战，优秀的程序员一定要征服种种挑战。我一直觉得自己是一个非常优秀的程序员。因此，尽管每天晚上我都以失败告终，只能上床睡觉，但我内心深处的某些东西是不会让我就此放弃的——第二天早上，我会带着新的想法和新的动力满血复活。 这样的循环已经持续几个月，这就像一场梦，日复一日，迟迟没有苏醒的一刻。我要处理的任务很简单：获取数据，保存数据，完事。但面
Ruby 中所有的数据结构和值都是对象，包括基本的数字和字符串以及数组 Array、散列表 Hash 这样的复杂数据结构。
而Push消息是这么多种类型之中非常重要和常用的一种类型，最近也希望针对Push推送做些新的尝试，于是去学习学习些Push消息运营的技巧。
APP给你推送的各种消息，这叫PUSH，营销广告邮件，这叫PUSH，营销短信，这也叫PUSH，网站上蹦出来的弹窗，这还叫PUSH，公众号的每日推送，这个…你也可以理解成PUSH。 简单理解，PUSH消息就是官方主动发送给用户的一切内容，可以是文字、图片、语音、视频，目的只有一个，让用户点进来看，看完了在APP里打着滚的接着看。 那么用户给用户发的消息呢？比如微信好友给你发了条消息，你收到了提醒，抱歉，这不叫push，这叫消息提醒。
假设，我们mq服务器上有上万条未处理的消息，我们随便打开一个消费者客户端，会出现什么样的情况呢？
首先我们来看一下消息的传输流程。消息生产者–>MQ–>消息消费者；消息生产者发送消息到MQ服务器，MQ服务器存储消息，消息消费者监听MQ的消息，发现有消息就消费消息。
如果投递出去的消息在网络传输过程中丢失，或者在RabbitMQ的内存中还没写入磁盘的时候宕机，都会导致生产端投递到MQ的数据丢失。
应用操作内容：由客户端发送的请求，需要被复制状态机（replicated state machine）执行的命令，如上是一个KV系统，每一次的操作是对某个key的内容。
最近我们公司在招开发，实习社招都有。我收到的简历很多，但认真投递的、符合要求的却寥寥无几，而且都是我自己看简历、选人、回复、面试，让本就饱和的工作量更加雪上加霜，到最后真的是身心俱疲了。
2、我们建立一个BookService.java并为相关方法加上@RabbitListener注解，启动服务器：
实际上，UDP并不是像大家想象中的那样不可信，它只是因为简单，才让你有这样的认知。从另一个角度来说，它其实是最纯洁的传输层协议。
Kafka 通过 消费组协调器 (GroupCoordinator) 与消费者协调器 (ConsumerCoordinator)，实现消费者再均衡操作。
在InfoQ播客的这一集中，查尔斯·哈姆伯与迈克尔·佩里谈论了他的书《永恒架构的艺术》。他们讨论的主题包括分布式计算的八个谬误：由L Peter Deutsch和Sun Microsystems的其他人提出的一组断言，描述了新加入分布式应用程序的程序员总是做出的错误假设。其他主题包括Pat Helland的论文“不变性改变一切”、Eric Brewer的CAP定理、最终一致性、位置无关身份和CRDT。他们还讨论了如何将Perry倡导的构建分布式系统的方法引入到需要与可变下游系统集成的真实企业应用程序中。
在socket网络编程中，如果此时客户端忽然由于某种原因断开连接或者崩溃，服务端没有处理好，便会同时崩溃掉，本篇文章将会从崩溃到问题分析，解决，一步步入手。
在项目中使用RabbitMQ时，我们可能会遇到这样的问题:如一个订单系统当用户付款成功时我们往消息中间件添加一条记录期望消息消费者修改订单状态，但是最终实际订单状态并没有被修改成功。遇到这种问题我们排查的思路如下:
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
