Nodes Unable to communicate with each other

75 views

Skip to first unread message

Mutalik, Rajeev

unread,

Feb 14, 2012, 9:39:32 AM2/14/12

to haze...@googlegroups.com

Hi,

I have a module which implements hazelcast for communicating with each other (when deployed on two servers). When I tried to configure the TCP-IP settings programmatically I am getting following error:

[#|2012-02-13T09:02:16.289+0100|WARNING|sun-appserver2.1|
com.hazelcast.nio.OutSelector|_ThreadID=137;_ThreadName=hz.
1.OutThread;_RequestID=2c378033-8a09-42c1-9ab3-0a19b6482818;|[dev]
Connection refused
java.net.ConnectException: Connection refused
at sun.nio.ch.Net.connect(Native Method)
at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:
500)
at com.hazelcast.nio.OutSelector
$Connector.run(OutSelector.java:100)
at
com.hazelcast.nio.SelectorBase.processSelectionQueue(SelectorBase.java:
102)
at com.hazelcast.nio.SelectorBase.run(SelectorBase.java:117)
at java.lang.Thread.run(Thread.java:662)
|#]

So I wrote config file and creating hazelcastinstance from that config file. Now though I am not getting that error, the problem I am facing is two nodes are unable to communicate with each other.

Can you please have a look at the config file and Java code and let me know if I have missed out anything in this. I am using hazelcast-all-1.9.4.8.jar file.

Config file:

<hazelcast xsi:schemaLocation="http://www.hazelcast.com/schema/config hazelcast-basic.xsd"

xmlns="http://www.hazelcast.com/schema/config"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">

<multicast-group>224.2.2.3</multicast-group>

<multicast-port>54327</multicast-port>

</multicast>

<tcp-ip enabled="true">

<hostname>machine1</hostname>

<hostname>machine2</hostname>

</tcp-ip>

</network>

</hazelcast>

Java Code:

private void init() {

logger.debug("{}: Intialising", myName);

if (!initialised) {

initialised = true;

String xmlFileName = "/hazelcastConfig.xml";

InputStream inputStream = this.getClass().getResourceAsStream(xmlFileName);

hzConfig = new XmlConfigBuilder(inputStream).build();

logger.debug("{}: Port for hazel cast is " + hzConfig.getPort(), myName);

hazelcastInstance = Hazelcast.newHazelcastInstance(hzConfig);

Cluster cluster = hazelcastInstance.getCluster();

cluster.addMembershipListener(this);

Set<Member> members = cluster.getMembers();

Iterator<Member> iterator = members.iterator();

while (iterator.hasNext()) {

Member member = (Member) iterator.next();

if (member.getInetSocketAddress().getAddress().getHostAddress().equalsIgnoreCase(hazelCastConfiguration.getHazelCastOtherNodeIp()) ||

member.getInetSocketAddress().getHostName().equalsIgnoreCase(hazelCastConfiguration.getHazelCastOtherNodeIp())) {

otherNodeActive = true;

}

if (otherNodeActive) {

logger.debug("{}: Other node is active", myName);

} else {

logger.debug("{}: Other node is not active", myName);

}

deliverQueue = hazelcastInstance.getQueue(DELIVER_SM_QUEUE);

deliverQueue.addItemListener(this, true);

bindMap = hazelcastInstance.getMap(BIND_MAP);

}

Output in glassfish logs (It is similar for other node/machine except that the ip address changes which is highlighted in red below):

|#]

|#]

|#]

|#]

|#]

|#]

|#]

[#|2012-02-14T15:21:02.987+0100|INFO|sun-appserver2.1|com.hazelcast.impl.Node|_ThreadID=90;_ThreadName=hz.1.ServiceThread;|[dev]

Members [1] {

Member [158.234.57.6:5901] this

}

|#]

|#]

There is a difference of around 1-2 mins between starting of two nodes.

Also please refer:

http://groups.google.com/group/hazelcast/browse_thread/thread/967c02a9821445b5

Thanks and Regards,
Rajeev Mutalik

Think green - keep it on the screen. This e-mail and any attachment is for authorised use by the intended recipient(s) only. It may contain proprietary material, confidential information and/or be subject to legal privilege. It should not be copied, disclosed to, retained or used by, any other party. If you are not an intended recipient then please promptly delete this e-mail and any attachment and all copies and inform the sender. Thank you.

Fuad Malikov

unread,

Feb 29, 2012, 2:38:06 AM2/29/12

to haze...@googlegroups.com

Your config file doesn't have group name and password. It states that

"Neither multicast nor tcp/ip join is enabled! Starting standalone"

Somehow the config that you provide doesn't have TCP/IP enabled. Make sure you do provide the correct config. You can try creating config programmatically.

-fuad

--
You received this message because you are subscribed to the Google Groups "Hazelcast" group.
To post to this group, send email to haze...@googlegroups.com.
To unsubscribe from this group, send email to hazelcast+...@googlegroups.com.
For more options, visit this group at http://groups.google.com/group/hazelcast?hl=en.

Reply all

Reply to author

Forward

0 new messages