jgroup配置.docx

4 Protocol Stack4．1 Transport protocols??? Transport protocols是指协议栈中最底层的协议，它们负责发送和接收消息。JGgroups提供了以下几种transport protocols。4．1．1 UDP??? JGroups中的UDP协议使用IP multicast向集群发送消息，使用UDP datagram向单个的成员发送unicast消息。启动后会打开两个socket，分别是multicast socket和unicast socket。Channel的地址是unicast socket的地址和端口号。UDP通常用于集群中的成员分布于LAN内的情况。??? 如果使用UDP和PING做为协议栈的底层协议，那么JGroups会使用IP multicast发现集群中的成员，以及向集群发送发送消息。然而，如果IP multicast在子网间被禁用，那么可以设置UDP的ip_mcast属性为false，以便指定UDP使用多个unicast messages向集群发送消息，而不是使用multicast message。此外，还需要设置PING的gossip_系列属性，以便指定PING使用GossipRouter来发现集群中的其它成员。需要注意的 是，对GossipRouter的依赖可能会导致single point of failure，而且系统的可伸缩性也比较差。??? 在启动任何成员之前，首先要启动GossipRouter（否则成员需要处理MergeView消息用于合并subgroup的状态），例如：Java代码 ?java?org.jgroups.stack.GossipRouter?-port?5555?-bindaddress?localhost????? UDP和PING的配置如下：Xml代码 ?UDP?ip_mcast=false?/??PING?gossip_host=localhost?gossip_port=5555?gossip_refresh=15000?timeout=2000?num_initial_members=3/??4．1．2 TCP??? 当集群中的成员分布于WAN时（路由器会丢弃IP multicast报文），TCP可能是唯一可用的传输协议。当使用TCP作为传输协议是，可用的发现协议有：PING with GossipRouter: 跟4.1.1中介绍的一样，p_mcast属性必须设置成false，GossipRouter 也必须先于集群中的成员启动。TCPPING: 从特定已知的成员处得到集群中其它成员的信息。TCPGOSSIP: 除了允许多个GossipRouters 之外，TCPGOSSIP 跟PING相同。??? 以下是个使用TCP和TCPPING的例子：Xml代码 ?TCP?start_port=7800?/?+??TCPPING?initial_hosts=HostA[7800],HostB[7800]?port_range=5?timeout=3000?num_initial_members=3?/????? 使用TCPPING的优点是不需要额外GossipRouters，而是从集群的成员中选择那些已知的成员，例如以上例子中的HostA[7800]和 HostB[7800]，并从这些成员处得到其它成员的信息。TCP协议的start_port=7800属性指定了选择7800作为端口号，如果该 端口号被占用，那么尝试下一个（7801）端口号，直到找到可用的端口号。TCPPING协议会尝试连接HostA和HostB，连接的端口号的范围是从 7800到7800 + port_range -1（在以上例子中是7804）。??? 以下是个使用TCP和TCPGOSSIP的例子：Xml代码 ?TCP?/??TCPGOSSIP?initial_hosts=localhost[5555],localhost[5556]?gossip_refresh_rate=10000?num_initial_members=3?/????? 以上例子中，initial_hosts 属性用于指定GossipRouter的地址和端口号。GossipRouter需要先于集群中的成员启动。4．2 Reliable Message4．2．1 pbcast.NAKACK??? NAKACK协议保证了向集群的所有成员发送的消息的传输可靠性，以及消息的FIFO顺序。消息传输的可靠性是指发送的消息不会丢失。此外发送者将发送的 消息编号，如果接收者没有收到特定编号的消息，那么发送者会收到重新发送的请求。FIFO顺序是指接收者会以消息发送的顺序接收消息。以下是部分 NAKACK