Dubbo 是一个分布式、高性能、透明化的 RPC 服务框架,提供服务自动注册、自动发现等高效服务治理方案, 可以和Spring框架无缝集成。dubbo中消费者调用提供者原理 Provider:暴露服务方称之为“服务提供者” Consumer:调用远程服务方称之为“服务消费者” Registry:服 ...
分类:
其他好文 时间:
2019-11-02 16:11:54
阅读次数:
108
进程:进程是正在进行的一个过程或者一个任务。负责执行这个任务的是cpu进程与程序的区别:程序:仅仅只是一堆代码进程:是程序运行的过程并发与并行并发只能达到伪并行,看上去是同时进行的,其实并不是,单个cpu+多道技术就可以实现并发并行:是同时运行,必须具备多个cpu,才能实现并行的功能进程的状态其实在 ...
分类:
系统相关 时间:
2019-10-28 21:01:17
阅读次数:
93
消费者驱动的契约Consumer Driven Contracts (CDC)A contract between a consuming service and a providing service, stating what the consumer wants from a providin... ...
分类:
其他好文 时间:
2019-10-27 18:21:36
阅读次数:
96
初相识|performance_schema全方位介绍 |导 语 很久之前,当我还在尝试着系统地学习performance_schema的时候,通过在网上各种搜索资料进行学习,但很遗憾,学习的效果并不是很明显,很多标称类似 "深入浅出performance_schema" 的文章,基本上都是那种动不 ...
分类:
其他好文 时间:
2019-10-25 11:36:35
阅读次数:
99
建立kafka消费类ConsumerRunnable ,实现Runnable接口: 在编写一个类,用来初始化上面这个类,并通过线程启动 最后项目启动时先初始化一下ConsumerGroup这个类,在调用一下execute()方法就能进行消费 ...
分类:
编程语言 时间:
2019-10-24 09:45:43
阅读次数:
116
图解jdk1.8新特性(2) Lambda 简要说明 jdk常用函数式接口 Predicate 接口返回一个测试结果,结果类型为true或者false 支持and、or、negate方法 Consumer 接口接受一个参数,然后对该参数做消费,返回void 支持通过andThen方法来进行链式调用消 ...
分类:
其他好文 时间:
2019-10-23 20:13:56
阅读次数:
80
一、kafka环境配置 1.jdk安装 安装文件:http://www.oracle.com/technetwork/java/javase/downloads/index.html 下载JDK安装完成后需要添加以下的环境变量(右键点击“我的电脑” -> "高级系统设置" -> "环境变量" ): ...
package org.rx.util; import java.util.function.Consumer; import static org.rx.core.Contract.require; public class BufferSegment { private final byte[]... ...
分类:
编程语言 时间:
2019-10-23 11:48:45
阅读次数:
76
依赖于zookeeper,先搭建好zookeeper 集群部署 1)解压安装包 tar -zxvf kafka_2.11-0.11.0.0.tgz 2)修改解压后的文件名称 mv kafka_2.11-0.11.0.0/ /usr/local/kafka 3)在/usr/local/kafka目录下 ...
分类:
其他好文 时间:
2019-10-22 01:05:07
阅读次数:
92
sem mutex1=1; sem mutex2=1; sem empty=1000; sem full=0; producer() { while(1) { 生产一个产品 p(empty); p(mutex2); 放入缓冲区 v(mutex2); v(full); } } consumer() {... ...
分类:
其他好文 时间:
2019-10-20 20:08:19
阅读次数:
80