生产-消费者队列,用于多节点的分布式数据结构,生产和消费数据。生产者创建一个数据对象,并放到队列中;消费者从队列中取出一个数据对象并进行处理。在ZooKeeper中,队列可以使用一个容器节点下创建多个子节点来实现;创建子节点时,CreateMode使用PERSISTENT_SEQUENTIAL,ZooKeeper会自动在节点名称后面添加唯一序列号。EPHEMERAL_SEQUENTIAL也有同样的
分类:
其他好文 时间:
2019-08-23 14:54:18
阅读次数:
68
一、为什么要使用MQ 1. 异步:快速返回 2. 解耦:解除依赖 3. 削峰填谷 二、MQ的缺点 1. 系统可用性降低,因为MQ可能会挂 2. 系统复杂性提高,要考虑消息重复、丢失、顺序等问题 3. 数据一致性问题,生产者并不知道消费者是否真正消费了 三、怎么保证MQ消息不丢失 1. 生产者丢失数据 ...
分类:
其他好文 时间:
2019-08-23 00:23:39
阅读次数:
81
多线程(一) 1.多进程补充(生产者消费者模型) 2.线程 2.开启线程的两种方式 3.多进程与多线程对比 4.线程的相关其他方法 5.join方法与守护线程 6.互斥锁 ...
分类:
编程语言 时间:
2019-08-23 00:17:25
阅读次数:
109
订阅发布模式 [TOC] 1、交换器(Exchange) 在 背后,其实是 把每条任务消息只发给一个消费者。本篇中我们将要研究如何把一条消息推送给多个消费者,这种模式被称为 (发布/订阅) ![订阅发布模式][1] 的消息发送模型核心思想是生产者不直接把消息发送到消息队列中。事实上,生产者不知道自己 ...
分类:
其他好文 时间:
2019-08-21 21:43:57
阅读次数:
91
生产者,消费者模型 举个例子来说明,厨师,服务员,厨师做菜,服务员上菜,如果厨师没有做好菜,那么服务员就无法上菜,厨师做好了菜,然后通知服务员消费(上菜)。在这个过程之中,厨师扮演的就是生产者,服务员扮演消费者。 一句话说:生产者没有生产出来东西,消费者就必须等待着,生产者生产出来了,就通知消费者进 ...
分类:
其他好文 时间:
2019-08-21 00:31:12
阅读次数:
83
1.kafka是一个分布式消息队列。具有高性能、持久化、多副本备份、横向扩展能力。生产者往队列里写消息,消费者从队列里取消息进行业务逻辑。一般在架构设计中起到解耦、削峰、异步处理的作用。 1.1 broker:安装了kafka服务的机器称之为broker 1.2 topic(主题):是用来存放消息, ...
分类:
其他好文 时间:
2019-08-20 10:40:28
阅读次数:
73
同步锁 acquire([timeout])/release(): 调用关联的锁的相应方法。 wait([timeout]): 调用这个方法将使线程进入Condition的等待池等待通知,并释放锁。使用前线程必须已获得锁定,否则将抛出异常。 notify(): 调用这个方法将从等待池挑选一个线程并通 ...
分类:
编程语言 时间:
2019-08-20 00:35:52
阅读次数:
101
分布式锁有几种实现形式 n个线程同时并发-countdown zk配置中心,watch机制底层 zk分布式锁 并发的实践 说说springcloud组件 自己实现一个生产者、消费者 java 基本类型与包装类型 redis底层zset实现 mysql索引底层说一下 B+树 自平衡 myisam和in ...
分类:
其他好文 时间:
2019-08-19 23:11:43
阅读次数:
98
进程间通信 进程间通信IPC机制 生产者消费者模型 线程 什么是线程 进程线程其实都是虚拟单位,都是用来帮助我们形象的秒数某种事物 进程:资源单位 线程:执行单位 将内存比喻成工厂 那么进程就相当于是工厂里面的车间 而你的线程就相当于是车间里面的流水线 ps:每个进程都自带一个线程,线程才是真正的执 ...
分类:
其他好文 时间:
2019-08-19 21:28:17
阅读次数:
75
比如当前有个需求,需要拦截dubbo的服务提供方或者服务消费方的方法,判断参数中是否包含某个关键字进行拦截阻止执行,话不多说直接上代码: 1、新建一个类实现dubbo的Filter接口 2、META-INF下新建文件 文件内容为: 至此就可以成功的拦截你想拦截的东西 3、下面解释几个点: 1、关于@ ...
分类:
其他好文 时间:
2019-08-19 17:28:37
阅读次数:
137