Связь между JBOSS AppServer и Клиентом через многоадресную рассылку - PullRequest
Новая
       23

Связь между JBOSS AppServer и Клиентом через многоадресную рассылку

0 голосов
/ 28 октября 2009

Я новичок в JBOSS. Я пытаюсь написать mBean, который будет взаимодействовать из AS через многоадресный канал с использованием JGroups. Код, который я использую в моем mBean, ниже ... 

public void create() throws Exception {
channel=new JChannel("test/udp.xml");
channel.connect("ChatCluster");

} 

public void sendMsg() throws ChannelNotConnectedException,  
                                       ChannelClosedException {
 channel.send(new org.jgroups.Message(
                     null,null, "hello from the server!"));

}

Я также создал клиента, который прослушивает канал, но оба не общаются. Вот XML для канала. 

<UDP
     mcast_port="45700"
     mcast_addr="224.0.0.11"
     tos="8"
     ucast_recv_buf_size="20000000"
     ucast_send_buf_size="640000"
     mcast_recv_buf_size="25000000"
     mcast_send_buf_size="640000"
     loopback="true"
     discard_incompatible_packets="true"
     max_bundle_size="64000"
     max_bundle_timeout="30"
     ip_ttl="${jgroups.udp.ip_ttl:32}"
     enable_bundling="true"
     enable_diagnostics="true"
     thread_naming_pattern="cl"

     thread_pool.enabled="true"
     thread_pool.min_threads="2"
     thread_pool.max_threads="8"
     thread_pool.keep_alive_time="5000"
     thread_pool.queue_enabled="true"
     thread_pool.queue_max_size="10000"
     thread_pool.rejection_policy="discard"

     oob_thread_pool.enabled="true"
     oob_thread_pool.min_threads="1"
     oob_thread_pool.max_threads="8"
     oob_thread_pool.keep_alive_time="5000"
     oob_thread_pool.queue_enabled="false"
     oob_thread_pool.queue_max_size="100"
     oob_thread_pool.rejection_policy="Run"/>

Любая помощь будет принята с благодарностью, так как я потратил немного галстука на это и пытаюсь понять это. Я бы предпочел использовать какой-то другой механизм для общения, однако я ограничен только использованием многоадресной передачи ... длинная история ..

Спасибо !!!

~ Болт

Ответы [ 2 ]

0 голосов
/ 28 октября 2009

Оказалось, что в моей системе было несколько сетевых карт, поэтому я установил флаг receive_on_all_interfaces = "true".

0 голосов
/ 28 октября 2009

Ваша сеть настроена для многоадресной рассылки? Документация JGroups имеет несколько указателей. вещи не работают, и некоторые тестовые программы. См. Руководство по установке , раздел 2.6. Если ваша сеть в порядке, то просто 

java org.jgroups.demos.Draw

программа должна работать из коробки. Если это так, я бы взял известную конфигурацию JGroups, настроил вашу систему на нее и работал оттуда.

...