Router服务路由, 根据路由规则从多个Invoker中选出一个子集AbstractDirectory是所有目录服务实现的上层抽象, 它在list列举出所有invokers后,会在通过Router服务进行路由过滤。
Router接口定义
public
interface Router extendsComparable {
URL getUrl();
List> route...
分类:
其他好文 时间:
2014-12-03 21:30:29
阅读次数:
151
LoadBalance负载均衡, 负责从多个 Invokers中选出具体的一个Invoker用于本次调用,调用过程中包含了负载均衡的算法,调用失败后需要重新选择
LoadBalance接口定义
@SPI(RandomLoadBalance.NAME)
public
interface LoadBalance{
@Adaptive("loadbalance")
Invoker sel...
分类:
其他好文 时间:
2014-12-03 21:29:47
阅读次数:
162
要求: 分布在不同机器上的进程,同时扫描某个ftp目录,得到文件目录,下载文件,但是要保证每个文件都只被一个进程获取思路:1. 文件以RW方式打开,比较暴力 ,另FTP支持RW方式打开吗。。。没了解过2. 实现一个分布式锁, 2.1 redis: redis单机的事务能否实现? 应该可以,...
分类:
其他好文 时间:
2014-12-03 18:34:12
阅读次数:
252
要求
客户端有四个要求:
这需要作为参数: zookpeer的服务地址、znode的名字、将输出写入到一个文件的名称、一个可执行的参数。
它与znode获取相关的数据并开始执行。
如果znode发生变化,重启客户端重新提取内容和可执行文件。
如果znode消失,客户端可进行线程销毁。
程序设计
一般来说,zookpeer应用被分解成两个部分,一个保持...
分类:
编程语言 时间:
2014-12-03 14:21:47
阅读次数:
271
在几个月前改造dubbo时,netty4已经稳定很久了,一时手痒,按照netty3-rpc的源码克隆了一套netty4,在修正了大量的包、类型不同之后,基本保持了netty3的风格,并发量小或者数据包很小时,一切都很ok, 在进行大并...
分类:
Web程序 时间:
2014-12-03 00:34:20
阅读次数:
2437
同事刘阳使用dubbo服务器中配置mina作为网络传输层,发现大并发情况下,解码发生如下异常 014-12-01 18:00:44,652 [DubboServerHandler-10.1.19.13:20880-thread-164] WARN? alibaba.dubbo.remoting.exchange.co...
分类:
其他好文 时间:
2014-12-02 22:47:35
阅读次数:
1452
服务注册与发现的中心,服务的提供者将服务发布到注册中心,服务的使用着到注册中引用服务。
Dubbo的注册中心提供了多种实现,其实现是基于dubbo的spi的扩展机制的,使用着可以直接实现自己的注册中心。
@SPI("dubbo")
public
interface RegistryFactory {
/**
* 连接注册中心.
* 连接注册中心需处理契约...
分类:
其他好文 时间:
2014-12-02 22:42:45
阅读次数:
271
服务注册与发现的中心,服务的提供者将服务发布到注册中心,服务的使用着到注册中引用服务。
Dubbo的注册中心提供了多种实现,其实现是基于dubbo的spi的扩展机制的,使用着可以直接实现自己的注册中心。
@SPI("dubbo")
public interface RegistryFactory {
/**
* 连接注册中心.
* 连接注册中心需处理契约...
分类:
其他好文 时间:
2014-12-02 22:42:24
阅读次数:
226
下面我们来看下开源dubbo推荐的业界成熟的zookeeper做为注册中心, zookeeper是hadoop的一个子项目是分布式系统的可靠协调者,他提供了配置维护,名字服务,分布式同步等服务。对于zookeeper的原理本文档不分析,后面有时间在做专题。
zookeeper注册中心
Zookeeper对数据存储类似linux的目录结构,下面给出官方文档对dubbo注册数据的存储示例...
分类:
其他好文 时间:
2014-12-02 22:40:30
阅读次数:
346
一种方式是通过调用ClientGlobal类的初始化方法对配置文件进行加载,另一种是通过调用API逐一设置配置参数。后一种方式对于使用Zookeeper等加载属性的方式很方便。1. 加载配置文件:[java] view plaincopyprint?String configFileName = "...