7.配置服务提供者（生产者） 7.1.配置resources/application.yml. 值eureka.client.service-url(或serviceUrl).defaultZone是配置将服务注册到那个注册中心，server.port是自己服务占用的端口，spring。applic ...
分类：
编程语言 时间：
2019-12-20 13:38:34
阅读次数：
87
前言 使用Kafka也有一段时间了, 主要还是作为生产者推送数据到其它业务方, 作为生产者编写代码并不多, 因为客户端内部做了太多的处理, 同时也不太容易达到性能瓶颈, 大多情况也只是改变一下发送消息的路由策略. 即便如此面对众多参数如果不理解一条消息从发送到Kafka集群中间经历什么, 那么设置这 ...
分类：
其他好文 时间：
2019-12-19 09:42:19
阅读次数：
99
步骤： 1.生产者启动时会将自己的服务信息写入注册信息（ip /port /服务名称 ）； 2.注册中心会动态的管理服务信息 3.当消费者启动时，注册中心会将注册信息发送给消费者端，消费者并缓存到本地，方便消费者下次访问 4.当用户发起请求时，会经过http协议访问服务器消费者，服务器消费者经过负载 ...
分类：
其他好文 时间：
2019-12-18 14:29:17
阅读次数：
105
/** *LinkedTransferQueue是有容量的， * 当第一个生产者线程调用transfer时，如果没有消费者，会阻塞。 * 第二个生产者线程调用transfer时，如果没有消费者，会添加到队列的末尾。 * 直到有消费者进行消费时调用take方法，被阻塞的生产者线程才继续运行 */ /* ...
分类：
其他好文 时间：
2019-12-18 12:55:33
阅读次数：
48
队列： # 生产者 def producer(name, food, q): for i in range(20): time.sleep(random.random()) f = "%s 制作了的第%s个%s" % (name, i, food) print(f) # 将数据放入队列中 q.put ...
分类：
系统相关 时间：
2019-12-18 09:27:08
阅读次数：
105
1. 消息生产者、消息者、队列 消息生产者Producer：发送消息到消息队列。 消息消费者Consumer：从消息队列接收消息。 Broker：概念来自与Apache ActiveMQ，指MQ的服务端，帮你把消息从发送端传送到接收端。 消息队列Queue：一个先进先出的消息存储区域。消息按照顺序发 ...
分类：
其他好文 时间：
2019-12-17 22:01:53
阅读次数：
62
一、生产者springcloud_eureka_provider （1）目录展示 （2）导入依赖 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifac ...
分类：
编程语言 时间：
2019-12-17 18:54:19
阅读次数：
215
RabbitMQ是用来在多个异构系统之间进行数据交换的，生产者无需知道消费者的存在，消费者也无需关注生产者的行为，从而进行解耦，提高系统性能。 这里生产者只需要将数据送到队列里面，就完成了任务，而消费者只需要去某个队列消费，就接收到了数据。那么生产者是如何将数据送到指定的队列呢？这里就用到了交换机。 ...
分类：
Web程序 时间：
2019-12-17 00:36:57
阅读次数：
86
1. 环境 CDH 5.16.1 kafka版本 2.1.0 kafka 4.0.0 ~~~ org.apache.kafka kafka_2.12 2.1.0 kafka 4.0.0 ~~~ 2.生产者 2.1 生产者，带回调函数 ~~~ package com.monk.kafka; impor ...
一、导入依赖 二、生产者provider （1）目录展示 （2）配置文件application.properties （3）DoSomeService接口 package com.zn.service; public interface DoSomeService { public String s ...
分类：
编程语言 时间：
2019-12-14 15:56:17
阅读次数：
137
