如何在jgroup replicated hashmap中给状态转移超时？

如何在Jgroup集群中指定状态传输超时？如何在jgroup replicated hashmap中给状态转移超时？

public static ReplicatedHashMap<Integer, BaseSeatLayout> _baseSeatLayoutCache; 
JChannel baseRouteCache = new JChannel(props); 
baseRouteCache.connect("Master-Cluster"); 
client.startBaseRouteCache(baseRouteCache); 
_baseSeatLayoutCache = new ReplicatedHashMap<>(channel); 
_baseSeatLayoutCache.addNotifier(this); 
_baseSeatLayoutCache.start(10000); 
loadData()// This will load around 2 millions entry

相同的代码我正在子机（或机器2）上无loadData（）运行，但是，当我运行代码我得到为状态超时异常异常作为10000ms已经过去，只有一些部分数据越来越复制。我怎样才能改变初始状态转移的超时时间？

我使用TCP协议，我tcp.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="7800" 
     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:10.120.19.145[7800],localhost[7801]}" 
      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" /> 

    <pbcast.STATE_TRANSFER/> 
</config>

来源

2017-09-09 Hitesh Vaghani

_baseSeatLayoutCache.start(10000)

的10000 MS是超时;增加它或设置为0以等待完成状态转移。

来源

2017-09-10 12:12:51

是否可以在ReplicatedHashMap中传输10GB的数据？ –

是的。但是这意味着每个成员都必须在其缓存中具有10 * N GB的数据，其中'N'是缓存中成员的数量。我会使用_distributed_缓存而不是_replicated_，其中数据不会复制到所有成员，而只会被复制到子集。 “ReplCache”是JGroups中的一个示例（玩具）impl; Infinispan（infinispan.org）是一个真正的实现。 –

它更像是我希望在一台机器（即Master）中形成数据库并在其他机器（即从机）上复制相同的数据，以便其他机器不会在群集中加载任何内容，只能从主机读取数据。 –

如何在jgroup replicated hashmap中给状态转移超时？

回答

相关问题