natas_hw
/
dubbo
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改zookeeper实现 

git-svn-id: http://code.alibabatech.com/svn/dubbo/trunk@72 1a56cb94-b969-4eaa-88fa-be21384802f2
This commit is contained in:
william.liangf 2011-10-26 06:49:51 +00:00
parent 2ba8642e56
commit 718ec7cf68
1 changed files with 24 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
dubbo-registry-zookeeper/src/main/java/com/alibaba/dubbo/registry/zookeeper/ZookeeperRegistry.java
View File

@ -59,6 +59,9 @@ public class ZookeeperRegistry implements Registry {
private final ConcurrentMap<String, Map<NotifyListener, NotifyWatcher>> wathers = new ConcurrentHashMap<String, Map<NotifyListener, NotifyWatcher>>();
public ZookeeperRegistry(URL url) {
if (url == null) {
throw new IllegalArgumentException("registry url == null");
}
this.url = url;
try {
String address = url.getAddress();
@ -98,6 +101,9 @@ public class ZookeeperRegistry implements Registry {
}
public void register(URL url) {
if (url == null) {
throw new IllegalArgumentException("register url == null");
}
try {
String service = toServicePath(url);
String provider = service + toProviderPath(url);
@ -113,6 +119,9 @@ public class ZookeeperRegistry implements Registry {
}
public void unregister(URL url) {
if (url == null) {
throw new IllegalArgumentException("unregister url == null");
}
try {
String service = toServicePath(url);
String provider = service + toProviderPath(url);
@ -123,6 +132,12 @@ public class ZookeeperRegistry implements Registry {
}
public void subscribe(URL url, NotifyListener listener) {
if (url == null) {
throw new IllegalArgumentException("subscribe url == null");
}
if (listener == null) {
throw new IllegalArgumentException("subscribe listener == null");
}
try {
String service = toServicePath(url);
NotifyWatcher wather = new NotifyWatcher(this, url, listener);
@ -143,6 +158,12 @@ public class ZookeeperRegistry implements Registry {
}
public void unsubscribe(URL url, NotifyListener listener) {
if (url == null) {
throw new IllegalArgumentException("unsubscribe url == null");
}
if (listener == null) {
throw new IllegalArgumentException("unsubscribe listener == null");
}
String service = toServicePath(url);
Map<NotifyListener, NotifyWatcher> serviceWathers = wathers.remove(service);
if (serviceWathers != null && serviceWathers.size() > 0) {
@ -154,6 +175,9 @@ public class ZookeeperRegistry implements Registry {
}
public List<URL> lookup(URL url) {
if (url == null) {
throw new IllegalArgumentException("lookup url == null");
}
try {
String service = toServicePath(url);
List<String> providers = zookeeper.getChildren(service, false);