使用kafka的几种场景

ops/2024/10/25 12:20:09/

1.消息异步化

在一个分布式的微服务架构中,实现一个聊天的功能,小明和小红互相给对方发消息,如果有两个netty服务器,小明连的是netty服务器1,小红连的是netty服务器2,现在小明给小红发消息,但是服务器1上面没有小红的链接。这时就可以通过把发送的消息通过kafka同步给其他服务器,如果其他服务器有小红的连接就把消息传递下去,没有就不做处理。

2.消息广播

使得服务之间的业务变得解耦和

3.消息广播

因为kafka的特点就是高吞吐量,当高并发时,可以削峰来消除下游服务的流量峰值,用时间来换性能


http://www.ppmy.cn/ops/8370.html

相关文章

HTML知识点

知识点搜索网站 MDN 总的理解 这个东西是用来进行界面设计的,可以看成是一些简单的语法规则,然后创作者根据自己的审美,借助这个工具来进行创作 创建 创建一个html文件之后,输入!,连续点击三下tab键&a…

爬虫入门——Request请求

目录 前言 一、Requests是什么? 二、使用步骤 1.引入库 2.请求 3.响应 三.总结 前言 上一篇爬虫我们已经提及到了urllib库的使用,为了方便大家的使用过程,这里为大家介绍新的库来实现请求获取响应的库。 一、Requests是什么&#xff1…

【数据结构】5.ArrayList与顺序表

目录 1.线性表 2.顺序表 2.1接口的实现 3.ArrayList简介 4.ArrayList使用 4.1ArrayList的构造 4.2ArrayList常见操作 4.3ArrayList的遍历 4.4ArrayList的扩容机制 5.ArrayList的具体使用 5.1简单的洗牌算法 5.2杨辉三角 1.线性表 线性表是n个具有相同特性的数据元素…

mysqlySQL中启用慢查询日志并设置阈值

要在MySQL中启用慢查询日志并设置阈值,可以按照以下步骤进行: 编辑MySQL配置文件:打开MySQL的配置文件(通常是my.cnf或my.ini),在[mysqld]部分添加或修改以下行来启用慢查询日志并设置阈值: s…

面试 Python 基础八股文十问十答第一期

面试 Python 基础八股文十问十答第一期 作者:程序员小白条,个人博客 相信看了本文后,对你的面试是有一定帮助的!关注专栏后就能收到持续更新! ⭐点赞⭐收藏⭐不迷路!⭐ 1)Python的基本数据类型…

go拼接字符串的方法

相信大家在工作中遇到不少拼接字符串的情况,而且就是应为字符串的拼接导致程序在一定的情况下变慢,今天我就把多重拼接字符串的方式放在下面,大家可以根据自己的需要选择不同的拼接方法 func TestJoinString(t *testing.T) {dataInfo : []st…

flask 应用程序

flask 程序示例 创建 hello.py 文件: # 导入 Flask 模块。Flask 类的一个对象是 wsgi 应用程序。 from flask import Flask# 创建app对象, Flask构造函数将当前模块的名称(__name__)作为参数。 app Flask(__name__)# route() 函数是一个装饰器,它告诉应…

动态Web项目讲解+Demo

web流程演示 请求路径 请求路径明确要请求的是哪个servlet 请求方式 servlet含有两种请求方式:doGet和doPost doGet&doPost 返回数据就是httpResponse,返回给success 参数 包含在request当中 成功 上述流程任何一步都没出问题,就会…