我想让我的Java应用程序的一些实例相互协作。我尝试为此使用JGroups，但没有成功。我不使用JBoss，而只是普通的JGroups库4.0.3。
我试图用两个相互连接的实例制作一个“最小的工作示例”。我在单台机器上进行了测试。
一旦我运行了我的应用程序的两个实例，我期望它们将同时打印自己的地址和彼此的地址。我得到的是他们只是打印了自己的地址。看来他们没有设法彼此连接。
这是我的Java代码：
import org.jgroups.Address;
import org.jgroups.JChannel;
import org.jgroups.View;
public class Main {
public static void main(String[] args) throws Exception {
JChannel ch = new JChannel("./test.xml");
ch.connect("TestCluster");
final int SLEEP_TIME_IN_MILLIS = 1000;
while (true) {
checkNeighbors(ch);
try {
Thread.sleep(SLEEP_TIME_IN_MILLIS);
} catch (InterruptedException e) {
// Ignored
}
}
}
private static void checkNeighbors(JChannel channel) {
View view = channel.getView();
List<Address> addresses = view.getMembers();
System.out.println("NEIGHBORS:");
for (Address address : addresses) {
System.out.println(" " + address);
}
}
}
这是第一个过程的“ test.xml”：
<config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns="urn:org:jgroups"
xsi:schemaLocation="urn:org:jgroups http://www.jgroups.org/schema/jgroups.xsd">
<TCP bind_port="7950"
recv_buf_size="${tcp.recv_buf_size:130k}"
send_buf_size="${tcp.send_buf_size:130k}"
max_bundle_size="64K"
sock_conn_timeout="300"
thread_pool.min_threads="0"
thread_pool.max_threads="20"
thread_pool.keep_alive_time="30000"/>
<TCPPING async_discovery="true"
initial_hosts="${jgroups.tcpping.initial_hosts:localhost[7900],localhost[7950]}"
port_range="2"/>
<MERGE3 min_interval="10000"
max_interval="30000"/>
<FD_SOCK/>
<FD timeout="3000" max_tries="3" />
<VERIFY_SUSPECT timeout="1500" />
<BARRIER />
<pbcast.NAKACK2 use_mcast_xmit="false"
discard_delivered_msgs="true"/>
<UNICAST3 />
<pbcast.STABLE desired_avg_gossip="50000"
max_bytes="4M"/>
<pbcast.GMS print_local_addr="true" join_timeout="2000"
view_bundling="true"/>
<MFC max_credits="2M"
min_threshold="0.4"/>
<FRAG2 frag_size="60K" />
<!--RSVP resend_interval="2000" timeout="10000"/-->
<pbcast.STATE_TRANSFER/>
</config>
对于第二个过程，我只是将绑定端口更改为7900。
我的输出只是每个进程打印自己的地址，如下所示：
-------------------------------------------------------------------
GMS: address=CAPYBARA-PC-5951, cluster=TestCluster, physical address=fd5c:92d6:98b5:0:c5ee:90c9:e7b0:ceb2:7950
-------------------------------------------------------------------
NEIGHBORS:
CAPYBARA-PC-5951
NEIGHBORS:
CAPYBARA-PC-5951
NEIGHBORS:
CAPYBARA-PC-5951
NEIGHBORS:
CAPYBARA-PC-5951
NEIGHBORS:
CAPYBARA-PC-5951
我每次运行5951时都会更改为不同的数字。
有人知道我做错了什么吗？
最佳答案
您需要在bind_addr中定义TCP并在TCPPING中列出所有主机，例如如果您有2个进程在192.168.1.5::7950和192.168.1.6::7900上运行，则第一个成员的配置需要包括：
<TCP bind_addr="192.168.1.5" bind_port="7950">
<TCPPING initial_hosts="192.168.1.5[7950],192.168.1.6[7900]"/>
第二个成员的配置应包括：
<TCP bind_addr="192.168.1.6" bind_port="7900">
<TCPPING initial_hosts="192.168.1.5[7950],192.168.1.6[7900]"/>
如您所见，
TCPPING列出了所有成员的绑定地址及其端口。您可以通过使用系统属性来使用相同的配置，例如
<TCP bind_addr="${my.bind_addr:192.168.1.6}" bind_port="${my.bind_port:7900}"> and start a process with `-Dmy.bind_addr=1.2.3.4` and `-Dmy.bind_port=12345`.
还要检查JGroups手册中绑定地址的符号名，例如
localhost，site_local或match-address:xxx。关于java - 具有TCPPING的JGroups(静态对等列表)，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/44522417/