RocketMQ是阿里开源的分布式消息中间件,跟其它中间件相比,RocketMQ的特点是纯JAVA实现;集群和HA实现相对简单;在发生宕机和其它故障时消息丢失率更低。 一.RocketMQ专业术语 Producer(生产者) 消息生产者,位于用户的进程内,Producer通过NameServer获取 ...
分类:
其他好文 时间:
2019-12-07 23:06:19
阅读次数:
134
1.子进程回收资源的两种方式: - 1) join让主进程等待子进程结束,并回收子进程资源,主进程再结束并回收资源。 - 2) 主进程 “正常结束” ,子进程与主进程一并被回收资源。 2.僵尸进程与孤儿进程(了解) 2.守护进程 当主进程结束时,子进程也必须结束,并回收。 3.进程间数据是隔离的 4 ...
分类:
其他好文 时间:
2019-12-07 21:06:23
阅读次数:
79
[toc] acks 这个参数用老指定分区中必须由多少个副本收到消息,之后生产者才会认为这条消息写入是成功的。acks参数有三种类型的值(都是字符串类型)。 acks=1 默认值为1.生产者发送消息之后,只要分区的leader副本成功的写入消息,生产端就会收到来自服务端的成功响应,说明发送成功。如果 ...
分类:
其他好文 时间:
2019-12-07 16:34:14
阅读次数:
268
1 概述 目前我们部分系统还在使用Kafka0.8.2.2 的版本。 0.8.2.2版本发行于2014年10月28号,距今已经过去4年多的时间。 三年的时间,Kafka截至到(2018-02-28),已经累计发布了14个版本,最新版本为1.0.0,由此,0.8.2已经远远落后于Kafka的最新版本1 ...
分类:
其他好文 时间:
2019-12-07 14:12:04
阅读次数:
856
进程同步是对多个相关进程在执行次序上进行协调,使并发执行的多个进程之间按照一定的规则共享系统资源。 1、生产者消费者问题: 生产者、消费者问题生产者生产产品放入缓冲区中,消费者从缓冲区中取出产品去消费。不允许消费者从空缓冲区中取产品,也不允许生产者向已经满了的缓冲区添加产品。 2、过程描述: 生产者 ...
分类:
系统相关 时间:
2019-12-07 12:11:48
阅读次数:
405
生产者: # !/usr/bin/env python # -*- coding: utf-8 -*- import pika # 创建连接对象 connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhos ...
分类:
其他好文 时间:
2019-12-07 01:30:09
阅读次数:
105
生产者: # !/usr/bin/env python # -*- coding: utf-8 -*- import pika # 创建连接对象 connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhos ...
分类:
其他好文 时间:
2019-12-07 01:09:11
阅读次数:
72
LinkedTransferQueue 功能 全名 简述 基于链表的的无界队列。队列的头是某个生产者在队列中停留时间最长的元素。队列的尾部是某个生产者在队列中时间最短的元素。 注意,与大多数集合不同,size方法不是一个常量时间操作。由于这些队列的异步性,确定当前元素的数量需要遍历元素,因此如果在遍 ...
分类:
其他好文 时间:
2019-12-06 19:16:37
阅读次数:
96
一、发送消息到队列(生产者)新建一个maven项目,在pom.xml文件加入以下依赖<dependencies><dependency><groupId>com.rabbitmq</groupId><artifactId>amqp-client</artifactId><version>3.6.5</vers
分类:
编程语言 时间:
2019-12-06 15:12:16
阅读次数:
78
一个topic有多个partition,每个partition又有多个副本,在这些副本中又有一个leader和多个follower。 1)分区的原因 (1)方便在集群中扩展,每个Partition可以通过调整以适应它所在的机器,而一个topic又可以有多个Partition组成,因此整个集群就可以适 ...
分类:
其他好文 时间:
2019-12-06 00:31:27
阅读次数:
192