为了保证通信质量和服务质量，我们需要制定靠谱的协议，下面我们的分析的过程就是来学习制定好的协议需要考虑什么因素
考虑最简单的点对点通信，只有一个发送者和一个接收者 ...
分类：
其他好文 时间：
2021-06-02 13:44:44
阅读次数：
0
Kafka概述 Kafka是一个基于发布、订阅的分布式消息队列,用于大数据实时处理。 为什么要用kafka? 注册信息的过程,先在网站上填写注册信息,后台会调用其他服务的接口,反馈给网页注册成功信息,最后再显示给用户,并且将短信发送给用户,该过程为同步通信过程,需要同步等待，由于同步通信的过程比较慢 ...
分类：
其他好文 时间：
2021-06-02 12:12:15
阅读次数：
0
6.6 观察者模式 6.6.1 概述 定义： 又被称为发布-订阅（Publish/Subscribe）模式，它定义了一种一对多的依赖关系，让多个观察者对象同时监听某一个主题对象。这个主题对象在状态变化时，会通知所有的观察者对象，使他们能够自动更新自己。 6.6.2 结构 在观察者模式中有如下角色： ...
分类：
其他好文 时间：
2021-06-02 10:48:29
阅读次数：
0
python 实现 kakfa 的 生产消费模式 和 发布订阅模式（已安装好 kafka 的情况下） 生产者 producer_demo.py from kafka import KafkaProducer, KafkaConsumer from kafka.errors import kafka_ ...
分类：
编程语言 时间：
2021-05-24 16:44:34
阅读次数：
0
3.5 面向连接的运输：TCP 3.5.1 TCP连接 面向连接：两个进程必须握手，相互发送预备报文段来确保数据传输的参数，初始化和TCO连续相关的状态变量 TCP协议在端系统中运行，中间的网络元素对连接是忽视的，看到的是数据报 TCP连接是点对点，只在连接双方 客户先发送一个特殊的TCP文段，服务 ...
分类：
其他好文 时间：
2021-05-24 05:01:33
阅读次数：
0
1 package com.bjsxt; 2 3 import jdk.jfr.events.SocketReadEvent; 4 5 import java.io.BufferedReader; 6 import java.io.IOException; 7 import java.io.Inpu ...
分类：
其他好文 时间：
2021-05-24 04:26:43
阅读次数：
0
# 发布订阅## subscribe订阅一个或者多个频道## publish给指定的频道发送消息## psubscribepsubscribe zzj.*订阅指定模式的频道，*代表所有## pubsub channels查看当前活跃的频道## pubsub numsub channels查看当前频道 ...
分类：
系统相关 时间：
2021-05-24 04:08:13
阅读次数：
0
1，什么是发布订阅模式？ 在软件架构中，发布订阅是一种消息范式，消息的发送者（称为发布者）不会将消息直接发送给特定的接收者（称为订阅者）。而是将发布的消息分为不同的类别，无需了解哪些订阅者（如果有的话）可能存在。同样的，订阅者可以表达对一个或多个类别的兴趣，只接收感兴趣的消息，无需了解哪些发布者（如 ...
分类：
编程语言 时间：
2021-04-29 11:56:52
阅读次数：
0
以下介绍redis的几种类型：List、Pub/Sub、Stream 场景 List Pub/Sub Stream 阻塞式消费 支持 支持 支持 发布/订阅 不支持 支持 支持 重复消费 不支持 不支持 支持 持久化 支持 不支持 支持 消息堆积 内存持续增长 缓冲区溢出，消费者强制下线 可控制队列 ...
分类：
其他好文 时间：
2021-04-24 13:46:07
阅读次数：
0
通过对 Zookeeper 中丰富的数据节点进行交叉使用，配合 Watcher 事件通知机制，可以非常方便的构建一系列分布式应用中涉及的核心功能，比如 数据发布/订阅、负载均衡、命名服务、分布式协调/通知、集群管理、Master 选举、分布式锁和分布式队列 等功能 1. 数据发布/订阅 当某些数据由 ...
分类：
其他好文 时间：
2021-04-20 15:29:56
阅读次数：
0
