消息队列以及非常牛的kafka

目录

概念

例子比较

传统串行服务

引入消息队列

事务

socket

MQ的两种流派

1、有broker

2、无broker

kafka使用场景

卡夫卡的基本理念

kafka的安装

考虑信件队列 :

1. 所有对计算机有基本了解的人都了解排队是什么,首先排队是管子。

因此,让我们来看看什么是突发新闻!

概念

2. 信息查询(MQ),在信息队列的中间,许多初学者认为,MQ通过以不规则方式发送和接收信息来完成操作。mq主要用于非同步任务。这不是MQ的真正目的 只是MQ的用途 Mq的真正目标是交流。 他像往常一样,阻碍复杂的通讯技术。https协议在 Dubbo 中同步 。两个协定之间的双向沟通是难以完成的。 接触B和B也可以主动与A联系。不支持长连接。Mq公司根据这些协定构建了一项基本协议--生产者、消费者模式。Mq没有向我们提供二流通讯议定书。这是一个更先进的通信模式。他定义了两个对象:数据生成器和数据接收器。消费者是给新闻取的名字。我们可以无视低级通信安排。生产者和消费者可以由我们来定义。

例子比较

让我们以寻宝令为例 来对比旧的串通服务 和更频繁的交流方式

传统串行服务

如果我们想买任何东西,就需要多走几步,才能发出成功信号,这需要很长时间,很容易造成错误,当网络波浪发生时,它将导致任务失败。

传统串通服务提供以下优势:基本的系统设计和容易的错误筛选。

传统串通服务有以下缺点: 1. 连接对两个系统来说太强了。 它不是系统的一部分。 完成这个系统需要很长时间。

引入消息队列

引入消息队列后，当在处理新订单是，信件一收到即转发到信件队列。订单成功后会通知客户剩下的处理操作，由消息队列来处理。大大减少了耗时。此外,后续进程不相互互动。因为他们正在按部就班地执行程序。这就降低了耦合性，提高了性能。

有个问题要我们考虑一下:

各队列只订阅一次服务,如何解决重复通知的问题?

当使用分布式锁服务订阅一个信息队列时,则将信息队列锁定,其他服务则无法订阅。

事务

只要信息排队参与,这个问题无疑将得到解决。

服务:原子论,我的所有活动要么是执行要么不是执行。

例如,如果张三转我100美元,它可以分为两部分:三个账户减少100美元,100个账户加到我的账户。

socket

1. 插座是一个很长的连接,用于快速通信。

2- 常规 http 请求一旦服务返回到客户信息两者之间的联系消失了。因此,如果你想联系你的委托人, 你需要四处打听。尽管如此,这是更昂贵的一轮调查。这不仅仅是客户寿终期工作的成本, 也是客户寿终期工作的成本。又消耗服务器资源，这就是:长链概念。

MQ的两种流派

1、有broker

经纪人是一个中转站,将信息传送到各队列。

(1) 新闻通过广播广播广播。

（2）等待消息请求

中间商分为两类。

1、重topic

Kafka:世界上最快的 mq 信息处理系统。

火箭:Ali内部一个伟大的神,根据Kafka的处决原则,用手写成,其性能与Kafka相似,但比Kafka的性能,例如按消费顺序排列,比Kafka的性能要多。

2、轻topic

没有主题,主题只是一条运输路线。

rabbitmq

2、无broker

零点:不使用经纪人;通讯直接通过插座进行。

kafka使用场景

1 日志收集:卡夫卡可以收集各种服务的日志,并通过一个一致的接口提供给一系列用户。

2 信息系统:将生产者和生产者分离,数据缓存

3 用户活动跟踪:kafka可以记录网站应用程序或用户行为,如访问网站、点击等,随后可转发给kafka,并接受这些信息的订阅监测。

可采用业务指标监测数据。

卡夫卡的基本理念

Kafka是一个分布式分区,提供信息系统功能。

kafka的安装

可以来看这篇博客

http://t.csdn.cn/LYJ3b

考虑信件队列 :

了解新闻队列后, 请考虑新闻队列问题。 这也是传统新闻堆, 例如, 当客户每秒生成一万条信息, 而消费者却收到一百条信息时, 也是一种传统新闻堆。

-------------------------------------------------------------

|

|

|
|

|

答案：

1. 增加从你那里购买的人的数量,如果买不到,则寻找更多的消费者来完成这项工作。

2. 限制客户的流量和每秒生成的信息的数量。

本文由 在线网速测试 整理编辑，转载请注明出处，原文链接：https://www.wangsu123.cn/news/21548.html。