JGroups:发送( null，null，Message)vs发送(Address，null，Message)
JGroups:发送( null，null，Message)vs发送(Address，null，Message)
提问于 2011-09-28 15:52:29
我已经编写了使用JGroups的简单测试。有两个这样的简单应用程序
import org.jgroups.*;
import org.jgroups.conf.ConfiguratorFactory;
import org.jgroups.conf.ProtocolConfiguration;
import org.jgroups.conf.ProtocolStackConfigurator;
import java.util.List;
/**
* @author Sergii.Zagriichuk
*/
public class Test {
public static void main(String[] args) throws Exception {
JChannel ch = new JChannel();
ch.setReceiver(new ReceiverAdapter() {
public void receive(Message msg) {
System.out.println("received message " + msg.getObject());
}
});
ch.connect("one");
}
}还有这个
package com.datacradle.example;
import org.jgroups.Global;
import org.jgroups.JChannel;
import org.jgroups.Message;
import org.jgroups.conf.ConfiguratorFactory;
import org.jgroups.conf.ProtocolConfiguration;
import org.jgroups.conf.ProtocolStackConfigurator;
import org.jgroups.stack.IpAddress;
import org.jgroups.util.SingletonAddress;
import org.jgroups.util.Util;
import java.util.List;
/**
* @author Sergii.Zagriichuk
*/
public class Test {
void start(String props) throws Exception {
JChannel chanel = new JChannel();
String line = "Test message";
chanel.connect("one");
// Message msg = new Message(null, null, new TestData(line, 1111, line + " Test suffix"));
Message msg = new Message(new IpAddress("fe33:0:0:0:1986:ba23:d939:f226%12",55435) , null, new TestData(line,1111,line+" sdfasdfasdfasdfasdfa"));
chanel.send(msg);
}
public static void main(final String[] args) throws Exception {
new Test().start(null);
}
}因此，如果我使用这种样式来创建消息
Message msg = new Message(null, null, new TestData(line, 1111, line + " Test suffix"));我将只收到一条消息(这是针对当前组中的所有订阅者)，但如果我使用此样式
Message msg = new Message(new IpAddress("fe33:0:0:0:1986:ba23:d939:f226%12",55435) , null, new TestData(line,1111,line+" sdfasdfasdfasdfasdfa"));我会收到很多消息，比如在循环中(这是针对一个dist地址)，问题出在哪里，或者我应该添加一些额外的参数吗？
P.S，JGroups 3.0.0 RC1
谢谢。
回答 1
Stack Overflow用户
回答已采纳
发布于 2011-09-29 06:21:47
您不应该使用IpAddress类创建成员地址，因为这是不透明的。我建议从视图中获取目标地址，例如
List<Address> members=channel.getView().getMembers();
Address target=members.get(0);
Message msg=new Message(target, null, "hello");
channel.send(msg);页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/7585958
复制
相似问题
IE7分区创建表
Jenkins-量角器集成-Centos7 7
Windows 7中的量角器
单击事件隐藏2分量角4
角度7量角器非角度LoginPage
添加站长 进交流群
领取专属 10元无门槛券
AI混元助手 在线答疑
关注 腾讯云开发者公众号
洞察 腾讯核心技术
剖析业界实践案例
腾讯云开发者
