基础概念 正所谓工欲善其事，必先利其器。我们先来了解一下kafka的基础构成。 producer 消息生产者，发布消息到kafka集群的终端或服务。 broker kafaka集群中包含的服务器 topic 每条发布到kafka集群的消息属于的类别，即kafka是面向topic的。 partitio ...
分类：
其他好文 时间：
2020-07-01 14:24:04
阅读次数：
73
今天上线时候碰到这么一个问题：由于上游生产者地址修改了，项目里面原来的消费者地址也要跟着修改。由于项目里面有两个消费者，之前的地址都是一样的。但是是两个不同的消费者，业务也是不同的。但是今天修改了第一个消费者的地址后，通过rocketmq的界面 发现 第二个的实例竟然也跑到了第一个上面。 问题如下： ...
分类：
其他好文 时间：
2020-06-30 20:39:06
阅读次数：
89
一般来说，消息队列有两种场景，一种是发布者订阅者模式，一种是生产者消费者模式。利用redis这两种场景的消息队列都能够实现。 定义： 生产者消费者模式：生产者生产消息放到队列里，多个消费者同时监听队列，谁先抢到消息谁就会从队列中取走消息；即对于每个消息只能被最多一个消费者拥有。 发布者订阅者模式：发 ...
分类：
其他好文 时间：
2020-06-30 17:09:14
阅读次数：
106
如今挂钟不仅是用来看看时间日历这些了，同时也是家里独具一格的装饰品，但市面上的挂钟品牌众多，价格、工艺等方面也各有不同，很多消费者就不知道该如何选购，究竟挂钟什么牌子好？我们常见的中国品牌有福建的瑞达、深圳的霸王、烟台的北极星、山东的康巴丝、广州的富达；但小编今天要推荐的挂钟是长沙本土的品牌——述泰 ...
分类：
其他好文 时间：
2020-06-30 13:16:48
阅读次数：
70
分区的原因 方便在集群中扩展 可以提高并发 生产者分区原则 有partition，直接用 有key，用key.hash%partition.length 无，随机生成整数M，用n*M%partition.length ProducerRecord(String topic,int partition ...
分类：
其他好文 时间：
2020-06-30 13:06:23
阅读次数：
51
一、消息队列 RabbitMQ是目前非常热门的一款消息中间件，不管是互联网大厂还是中小企业都在大量使用。 1.1 什么是消息队列 MQ全称为Message Queue，即消息队列。“消息队列”是在消息的传输过程中保存消息的容器。它是典型的：生产者、消费者模型。生产者不断向消息队列中生产消息，消费者不 ...
分类：
编程语言 时间：
2020-06-29 11:54:48
阅读次数：
71
注：安装的kafka版本为kafka_2.10-0.8.2.1，zookeeper版本选的是zookeeper-3.4.14 一.下载zookeeper 官网下载zookeeper-3.4.14.tar.gz,解压到相应目录下： 解压后的目录包含（修改conf目录下的zoo_sample.cfg文件 ...
分类：
其他好文 时间：
2020-06-29 11:27:17
阅读次数：
50
摘要 利用Python对MM131站点的分析，从而实现了整个站点的相关图片信息提取，并保存至本地硬盘。利用Python的multiprocessing库，threading库实现了高并发操作，大大加快对该站点的爬取效率。 1．引言 1.1背景 我们正处于飞速发展的大数据时代。不同于以往，现如今丰富的 ...
分类：
其他好文 时间：
2020-06-29 09:23:21
阅读次数：
329
所谓得汽车后市场是指汽车销售以后，围绕汽车使用过程中的各种服务，它涵盖了消费者买车后所需要的一切服务。也就是说，汽车从售出到报废的过程中，围绕汽车售后使用环节中各种后继需要和服务而产生的一系列交易活动的总称。汽车后市场大体上可分为七大行业：汽保行业；汽车金融行业；汽车IT行业；汽车精品、用品、美容、快修及改装行业又称汽车养护行业；汽车维修及配件行业；汽车文化及汽车运动行业；二手车及汽车租赁行业；后
分类：
其他好文 时间：
2020-06-28 18:17:26
阅读次数：
75
工作模式： 1、简单模式 HelloWorld : 一个生产者、一个消费者，不需要设置交换机（使用默认的交换机） 2、工作队列模式 Work Queue: 一个生产者、多个消费者（竞争关系），不需要设置交换机（使用默认的交换机） 3、发布订阅模式 Publish/subscribe: 需要设置类型为 ...
分类：
其他好文 时间：
2020-06-28 18:11:23
阅读次数：
46
