python 实现 kakfa 的 生产消费模式 和 发布订阅模式（已安装好 kafka 的情况下） 生产者 producer_demo.py from kafka import KafkaProducer, KafkaConsumer from kafka.errors import kafka_ ...
分类：
编程语言 时间：
2021-05-24 16:44:34
阅读次数：
0
一、Feign使用中存在的问题 我们在介绍Spring Cloud —— OpenFeign 核心原理2.2节时候，举了一个生产者消费者的案例，消费者服务在去调用生产者服务提供的接口时，我们需要定义定义 FeignClient 消费服务接口： @FeignClient(name= "nacos-pr ...
分类：
编程语言 时间：
2021-05-24 11:07:19
阅读次数：
0
大家好，这是一个为了梦想而保持学习的博客。这个专题会记录我对于KAFKA的学习和实战经验，希望对大家有所帮助，目录形式依旧为问答的方式，相当于是模拟面试。 一、写在前面 本来是打算写到消费者模块的时候再详细看一下和写一下rebalance过程，但是前阵子遇到的rebalance的问题比较多，发现自己 ...
分类：
其他好文 时间：
2021-05-24 00:09:26
阅读次数：
0
一、kafka Kafka是一个分布式的消息系统。 二、解决问题 消息系统通常被应用于异步处理、应用解耦、流量削峰、消息通信等场景。 异步处理 image-20210315230129937 生产者将消息写入消息队列中，消费者异步拉取消息队列消息，从而提升消息处理能力。 应用解耦 image-202 ...
分类：
其他好文 时间：
2021-05-23 23:45:42
阅读次数：
0
多进程 1 #方式一： 2 # from multiprocessing import Process 3 # import time 4 # 5 # def task(name): 6 # print('%s is running' %name) 7 # time.sleep(3) 8 # pri ...
分类：
编程语言 时间：
2021-05-04 15:51:14
阅读次数：
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/XMLS ...
分类：
其他好文 时间：
2021-05-03 12:04:13
阅读次数：
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 ProducerInfoMapper producerInfoMapper; @Autowired Rest ...
分类：
其他好文 时间：
2021-05-03 12:02:17
阅读次数：
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
