借助redis 实现多线程生产消费阻塞队列-kafka

请问有人做过下载限速相关的操作么,感觉下载太多,太集中了,带宽容易撑不住,有人坐过的话,提点下用什么插件

搜索一下 nginx 的限速和并发呢。

 

项目中实现——listMacStatus

AlarmSystemForTerminalController   
实现的思路——是不是用feign去访问另一个微服务,获取数据。然后这个接口是去kafka拿数据的?
        kafkaTemplate.send(HONEYWELL_TOPIC, "DEVICE_SSS_CCCCC_STATUS", GsonUtil.gson.toJson(jsonObject));

topic是    key是识别那个那条队列。这里写的是生产者者。意味生成消息吗?

 

public ListenableFuture<SendResult<K, V>> send(String topic, K key, V data) {
		ProducerRecord<K, V> producerRecord = new ProducerRecord<>(topic, key, data);
		return doSend(producerRecord);
	}

返回一个生产记录? 自己这边留个记录?

难道存在自定义的kafka product,和默认的?

 

 

 

 

 

 

 

 

 

霍尼韦尔警报系统-设备警报 服务实现类
AlarmDeviceAlarmServiceImpl

 

 

 

 

 

kafaka生产,消费

 暂时不怎么理解


版权声明:本文为weixin_44745624原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。