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

修改日志信息 

git-svn-id: http://code.alibabatech.com/svn/dubbo/trunk@167 1a56cb94-b969-4eaa-88fa-be21384802f2
This commit is contained in:
william.liangf 2011-11-01 13:30:17 +00:00
parent bd6c7988c3
commit 6b69ba93d1
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
dubbo-registry-multicast/src/main/java/com/alibaba/dubbo/registry/multicast/MulticastRegistry.java
View File

@ -49,9 +49,9 @@ public class MulticastRegistry extends AbstractRegistry {
private static final String UNSUBSCRIBE = "unsubscribe";
private InetAddress mutilcastAddress;
private final InetAddress mutilcastAddress;
private MulticastSocket mutilcastSocket;
private final MulticastSocket mutilcastSocket;
public MulticastRegistry(URL url) {
super(url);
@ -85,7 +85,7 @@ public class MulticastRegistry extends AbstractRegistry {
}
}
}
}, "MulticastRegistry");
}, "MulticastRegistryReceiver");
thread.setDaemon(true);
thread.start();
} catch (IOException e) {
@ -137,7 +137,7 @@ public class MulticastRegistry extends AbstractRegistry {
String service = url.getServiceKey();
if (getRegistered().containsKey(service)) {
for (URL u : getRegistered().get(service)) {
unicast(REGISTER + " " + u.toFullString(), url);
unicast(REGISTER + " " + u.toFullString(), url.getHost());
}
}
} else if (msg.startsWith(UNSUBSCRIBE)) {
@ -157,13 +157,13 @@ public class MulticastRegistry extends AbstractRegistry {
}
}
private void unicast(String msg, URL url) {
private void unicast(String msg, String host) {
if (logger.isInfoEnabled()) {
logger.info("Send unicast message: " + msg + " to " + url.getAddress() + ":" + mutilcastSocket.getLocalPort());
logger.info("Send unicast message: " + msg + " to " + host + ":" + mutilcastSocket.getLocalPort());
}
try {
byte[] data = (msg + "\n").getBytes();
DatagramPacket hi = new DatagramPacket(data, data.length, InetAddress.getByName(url.getHost()), mutilcastSocket.getLocalPort());
DatagramPacket hi = new DatagramPacket(data, data.length, InetAddress.getByName(host), mutilcastSocket.getLocalPort());
mutilcastSocket.send(hi);
} catch (Exception e) {
throw new IllegalStateException(e.getMessage(), e);