JGroups UDP multicast 问题!

0 0

JGroups UDP multicast 问题!15

请教一下大侠有关 JGroups UDP multicast的问题:

1. 发送端和接收端都必须要用JGroups才可以互相通讯吗, 如果发送端用JGroups, 接收端用普通JAVA API, 或者反过来的话, 可以通讯吗?(我测试的结果是不可以通讯, 不知道JGroups是不是像MQ那样, 发送端和接收端都得用它, 还是我测试不正确?)

2. 局域网内接收不到消息:
在一台机子上, 发送端用 JGroups UDP multicast 发送消息, 如果接收端也在同一台机子上, 则可以接收到消息. 如果发送端放在A机子上, 接收端放在B机子上(A和B都在同一局域网内), 则收不到消息, 为什么呢? (我用普通JAVA API写的发送端和接收端在局域网内通讯是没有问题的)(配置文件的内容在下面)

3. 消息丢包/重发的问题:
在消息发送频率高的情况下, 发送端发送的消息为msg1, msg2, msg3, msg4, msg5, msg6, msg7, msg8, msg9, msg10, msg11, 但是在接收端收到的消息可能为 msg3, msg3, msg3, msg5, msg5, msg7, msg7, msg9, msg9, msg11, msg11. 接收端收到的消息中, 有些重复, 有些丢失, 是不是配置方面的问题呢? (在消息发送频率比较高的情况下, 才会出现这个现象)

udp.xml配置文件如下:

<UDP     ip_mcast="true"
         bind_addr="127.0.0.1"         mcast_addr="${jgroups.udp.mcast_addr:239.9.9.9}"         mcast_port="${jgroups.udp.mcast_port:45588}"         
         tos="8"
         ucast_recv_buf_size="20M"
         ucast_send_buf_size="640K"
         mcast_recv_buf_size="25M"
         mcast_send_buf_size="640K"
         loopback="true"
         discard_incompatible_packets="true"
         max_bundle_size="64K"
         max_bundle_timeout="30"
         ip_ttl="${jgroups.udp.ip_ttl:8}"
         enable_bundling="true"
         enable_diagnostics="true"
         thread_naming_pattern="cl"

         timer_type="new"
         timer.min_threads="4"
         timer.max_threads="10"
         timer.keep_alive_time="5000"
         timer.queue_max_size="500"
         timer.rejection_policy="abort"

         thread_pool.enabled="true"
         thread_pool.min_threads="10"
         thread_pool.max_threads="100"
         thread_pool.keep_alive_time="5000"
         thread_pool.queue_enabled="true"
         thread_pool.queue_max_size="50000"
         thread_pool.rejection_policy="discard"

         oob_thread_pool.enabled="true"
         oob_thread_pool.min_threads="5"
         oob_thread_pool.max_threads="100"
         oob_thread_pool.keep_alive_time="5000"
         oob_thread_pool.rejection_policy="Run"/>

    <PING timeout="2000"
          num_initial_members="100"
          break_on_coord_rsp="true" />
    <MERGE2 max_interval="30000"
            min_interval="10000"
            merge_fast="false"/>
    <FD_SOCK/>
    <FD_ALL/>
    <VERIFY_SUSPECT timeout="1500"  />
    <BARRIER />
    <pbcast.NAKACK exponential_backoff="300"
                   xmit_stagger_timeout="200"
                   use_mcast_xmit="true"
                   discard_delivered_msgs="true"/>
    <UNICAST2 exponential_backoff="500"/>
    <pbcast.STABLE stability_delay="2000" desired_avg_gossip="60000"
                   max_bytes="4M"
                   cap="0.1"/>
    <pbcast.GMS print_local_addr="true"
                join_timeout="10000"
                view_bundling="true"
                max_bundling_time="1000"
                merge_timeout="5000"
                resume_task_timeout="15000"
            />
    <UFC max_credits="4M"
         min_threshold="0.4"/>
    <MFC max_credits="4M"
         min_threshold="0.4"/>
    <FRAG2 frag_size="60K"  />
    <pbcast.STATE_TRANSFER />

发送端的主要代码:

byte[] sentBytes = {xxxxxxx} // 生成发送字节数组的内容, 代码省略.

JChannel channel = new JChannel(new File(PathUtils.find("conf/udp.xml")));
    channel.connect("my_jgroups");
         while (true) {
                  channel.send(null, sentBytes);
                  Thread.sleep(1000); 
         }

接收端的主要代码:

JChannel channel = new JChannel(new File(PathUtils.find("conf/udp.xml")));
    channel.setReceiver(new ReceiverAdapter() {
        @Override
        public void receive(Message message) {
             System.out.println("received : " + new String(message.getBuffer()));
             }

        @Override
        public void viewAccepted(View view1) {
             System.out.println("received view : " + view1);
        }
    });

    channel.connect("my_jgroups");

各路大侠, 神仙, Help!