springCloud Bus 是什么? springCloud Bus 是用来将分布式系统的节点与轻量级消息系统连接起来的框架,它整合了java的事件处理机制和消息中间件的功能。 Bus支持两种消息代理:RabbitMQ和 Kafka。 作用: Bus可以管理和传播分布式系统间的消息,就像一个分布 ...
分类:
编程语言 时间:
2020-04-15 00:44:50
阅读次数:
114
概述 场景 服务解耦 削峰填谷 异步化缓冲:最终一致性/柔性事务 MQ应用思考点 生产端可靠性投递 消费端幂等:消息只能消费一次 高可用、低延迟、可靠性 消息堆积能力 可扩展性 业界主流MQ ActiveMQ:适合传统需求,并发性差 RabbitMQ:扩展性差 RocketMQ:扩展性强 Kafka ...
分类:
编程语言 时间:
2020-04-15 00:32:15
阅读次数:
107
前言 近期在研究各种消息队列方案,为了有一个直观的使用体验,我把Kafka,RocketMQ,RabbitMQ各自部署了一遍,并使用了最基本的生产与消费消息功能。在部署过程中也遇到一些问题,特此记录。本文只适用于没有使用过消息队列,还停留在安装部署阶段的新手用户,要了解一个软件,最好的开始方法是开始 ...
分类:
其他好文 时间:
2020-04-14 21:03:28
阅读次数:
69
接上一篇kafka环境搭建完成后,进入测试阶段,首先试一下最基本的生产与消费者。 1、创建topic,使用 kafka-topics.sh 创建 topic test bin/kafka-topics.sh --create --zookeeper localhost:2181 --replicat ...
分类:
其他好文 时间:
2020-04-14 19:05:32
阅读次数:
118
一,安装librdkafka sudo wget https://github.com/edenhill/librdkafka/archive/v0.9.4.tar.gz -O librdkafka-0.9.4.tar.gzsudo tar -zxvf librdkafka-0.9.4.tar.gz ...
分类:
Web程序 时间:
2020-04-14 17:00:45
阅读次数:
106
kafa部署在k8s中,并且使用statefulset 方式部署,应用pod连接kafka 使用 kafka-0.kafka-hs.sy-platform-demo.svc.cluster.local.:9093, 如果k8s 外部开发测试,无法连接,所以需要外部网络与pod service网络打通 ...
分类:
其他好文 时间:
2020-04-14 12:28:52
阅读次数:
321
单纯做后端的话,可以用FastAPI框架 1.服务端主动给客户端推送消息 截至目前为止,我们所写的web项目基本都是基于HTTP协议的 HTTP协议有四大特性:无链接(我请求 你响应 我俩没关系了 直接断开链接) 基于HTTP协议实现服务端主动给客户端推送消息好像有点麻烦~~~ 我们都经历过,浏览器 ...
分类:
其他好文 时间:
2020-04-13 21:07:25
阅读次数:
95
.ssm整合redis 导入依赖 编写配置文件,修改配置文件的ip,和端口 让spring的配置文件加载redis的配置 就可以直接使用redis了.再代码的任意位置,注入RedisTemplate就ok 2.redis作为缓存思路 先从redis中查询有没有数据 如果redis中没有热点数据,就从 ...
分类:
其他好文 时间:
2020-04-13 10:29:17
阅读次数:
87
下载源码 git clone -b 1.1.1 https://github.com/apache/kafka.git --depth=1 使用这样的方式下载主要是解决两个问题:其一,下载指定分支代码,这样不用下载最新代码然后切换到具体的tags。其二,因源码太大而只下载最新的depth可以增快下载 ...
分类:
其他好文 时间:
2020-04-13 10:22:05
阅读次数:
81
Kafka是一个分布式的、可分区的、可复制的消息系统。它提供了普通消息系统的功能,但具有自己独特的设计。这个独特的设计是什么样的呢 介绍 Kafka是一个分布式的、可分区的、可复制的消息系统。它提供了普通消息系统的功能,但具有自己独特的设计。这个独特的设计是什么样的呢? 首先让我们看几个基本的消息系 ...
分类:
系统相关 时间:
2020-04-12 18:19:48
阅读次数:
73