一、kafka Kafka是一个分布式的消息系统。 二、解决问题 消息系统通常被应用于异步处理、应用解耦、流量削峰、消息通信等场景。 异步处理 image-20210315230129937 生产者将消息写入消息队列中，消费者异步拉取消息队列消息，从而提升消息处理能力。 应用解耦 image-202 ...
分类：
其他好文 时间：
2021-05-23 23:45:42
阅读次数：
0
自己学习用，待补充！ pom： <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema- ...
分类：
其他好文 时间：
2021-05-03 12:02:46
阅读次数：
0
自己学习用，待补充！ 对比 LNC模块，就改一下 Controller （注解要换）： @Controller public class TccController { @Autowired ConsumerInfoMapper consumerInfoMapper; private static ...
分类：
其他好文 时间：
2021-05-03 12:01:21
阅读次数：
0
BUAA OO 第二单元总结 前言 ?本单元我们开始学习多线程程序设计。这对于我来说是一个全新的领域，在这之前我对于多线程这一方面几乎没有任何了解，因此这需要我继续认真学习。本单元需要我们模拟电梯系统的运行，这一个典型的生产者-消费者模型，具有清晰的结构，能够很好地让我们学习多线程相关知识，体会多线 ...
分类：
其他好文 时间：
2021-04-27 14:26:26
阅读次数：
0
以下介绍redis的几种类型：List、Pub/Sub、Stream 场景 List Pub/Sub Stream 阻塞式消费 支持 支持 支持 发布/订阅 不支持 支持 支持 重复消费 不支持 不支持 支持 持久化 支持 不支持 支持 消息堆积 内存持续增长 缓冲区溢出，消费者强制下线 可控制队列 ...
分类：
其他好文 时间：
2021-04-24 13:46:07
阅读次数：
0
canal源码及安装下载 https://github.com/alibaba/canal/releases canal(基于mysql数据库binlog的增量订阅&消费） - 简书 https://www.jianshu.com/p/6299048fad66 使用 Binlog 和 Canal 从 ...
分类：
数据库 时间：
2021-04-23 11:55:58
阅读次数：
0
03. Dubbo管理控制台 1. 作用 主要包含： 服务管理 路由规则 动态配置 服务降级 访问控制 权重调整 负载均衡等管理功能 如我们在开发时，需要知道Zookeeper注册中心都注册了哪些服务，有哪些消费者来消费这些服务。我 们可以通过部署一个管理中心来实现。其实管理中心就是一个web应用， ...
分类：
其他好文 时间：
2021-04-22 16:22:15
阅读次数：
0
需要使用幂等的场景： 前端重复提交 接口超时重试 消息队列重复消费 解决方案： token机制：①客户端请求获取token，服务端生成一个唯一ID作为token存在redis中；②客户端第二次请求时携带token，服务端校验token成功则执行业务操作并删除token，服务端校验token失败则表示 ...
分类：
其他好文 时间：
2021-04-22 16:19:38
阅读次数：
0
RabbitMQ主要实现消息推送和消费 用springboot实现消息推送 1. 新建springboot项目 通过idea，创建一个springboot默认项目，在pom.xml中添加如下依赖。 <dependency> <groupId>org.springframework.boot</gro ...
分类：
编程语言 时间：
2021-04-22 16:11:55
阅读次数：
0
模拟订阅报纸： 消费者与出版社之间没有联系，甚至互不相识，但报纸却从出版社到达了消费者手中，发布-订阅模式就是通过模拟订阅报纸，实现消息在模块之间的传递、模块与模块之间的调用。 Python样例 from blinker import Namespace # 创建一个Signal,其名为test m ...
分类：
其他好文 时间：
2021-04-16 11:41:15
阅读次数：
0
