[Clustering] Can not get connection to server

Voilà mon problème: j'ai deux serveurs Jboss sur la même machine, en clustering (node1 et node2).
Dans les répertoires deploy des deux serveurs j'ai déployé un ear, un jar et un war. Le war a besoin de l'ear et du jar.
J'utilise aussi Apache et mod_jk: je peux utiliser mon application web en appelant http://localhost/GuiClient-0.0.1-SNAPSHOT/, sans préciser le port (8080 pour node1, 8180 pour node2)

J'utilise deux nodes pour faire du failover.
J'utilise des EJBs dans mon application, et MySQL.

Quand j'exécute l'application, elle est exécutée en général par node1 (je peut vérifier par http://localhost/web-console/ sur quel node je suis redirigé).
Ça marche.
Puis, j'arrête le serveur node1, pour voir si le failover marche, si c'est node2 qui fait maintenant marcher l'application.
Le problème c'est que ça ne marche pas: j'obtiens l'erreur:

org.jboss.remoting.CannotConnectException: Can not get connection to server. Problem establishing socket connection for InvokerLocator [socket://127.0.0.1:3873/]
...
...
...
Caused by: java.net.ConnectException: Connection refused: connect

Ou bien:

javax.faces.FacesException: #{managedBean.elemCreate.createGraph}: org.jboss.remoting.CannotConnectException: Can not get connection to server. Problem establishing socket connection for InvokerLocator [socket://localhost:3873/]

(j'utilise dans mon war JSF/RichFaces).

node2 a bien pris le relais suite à l'arrêt de node1 (je le vois dans la console), mais l'application web ne veut plus remarcher.

Mon but, c'est de faire du failover: en cas de crash du serveur actif node1, le serveur node2 prend le relais de manière transparente pour l'utilisateur: l'application doit continuer à fonctionner comme si il n'y avait pas eu de crash serveur.

Tout cela est étrange : le port 3873 est utilisé pour les EJB3.

Est-ce que tu ne conserverais pas des choses inadéquates dans ta session, comme un contexte JNDI, une connexion vers un EJB3, ou autre bizarrerie ?

Concernant les EJB3, je ne les ai pas encore "clustered", je n'ai pas encore rajouté l'annotation @Clustered.

Si ce sont des stateless, ça n'a pas d'importance puisque ton application est censée accéder aux EJB locaux.

J'ai modifié mon appli: je suis passé au HAJNDI, et j'ai "clusterisé" les EJBs et les Entity Beans.

Maintenant, quand je fais crasher un serveur, j'ai ces messages d'erreurs dans la console Eclipse (je test plus par le navigateur pour le moment, je déploie plus mon war mais toujours mon ear et mon jar):

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
19:14:45,375  WARN ClusteringAspect:228 - Exception captured on createConnection... hopping to a new connection factory on server (-1)
org.jboss.jms.exception.MessagingNetworkFailureException
	at org.jboss.jms.client.delegate.DelegateSupport.handleThrowable(DelegateSupport.java:263)
	at org.jboss.jms.client.delegate.ClientConnectionFactoryDelegate.org$jboss$jms$client$delegate$ClientConnectionFactoryDelegate$createConnectionDelegate$aop(ClientConnectionFactoryDelegate.java:191)
	at org.jboss.jms.client.delegate.ClientConnectionFactoryDelegate$createConnectionDelegate_N3019492359065420858.invokeTarget(ClientConnectionFactoryDelegate$createConnectionDelegate_N3019492359065420858.java)
	at org.jboss.aop.joinpoint.MethodInvocation.invokeNext(MethodInvocation.java:111)
	at org.jboss.jms.client.container.StateCreationAspect.handleCreateConnectionDelegate(StateCreationAspect.java:81)
	at org.jboss.aop.advice.org.jboss.jms.client.container.StateCreationAspect_z_handleCreateConnectionDelegate_1027049.invoke(StateCreationAspect_z_handleCreateConnectionDelegate_1027049.java)
	at org.jboss.aop.joinpoint.MethodInvocation.invokeNext(MethodInvocation.java:102)
	at org.jboss.jms.client.delegate.ClientConnectionFactoryDelegate.createConnectionDelegate(ClientConnectionFactoryDelegate.java)
	at org.jboss.jms.client.container.ClusteringAspect.handleCreateConnectionDelegate(ClusteringAspect.java:134)
	at sun.reflect.GeneratedMethodAccessor30.invoke(Unknown Source)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.jboss.aop.advice.PerInstanceAdvice.invoke(PerInstanceAdvice.java:122)
	at org.jboss.aop.joinpoint.MethodInvocation.invokeNext(MethodInvocation.java:102)
	at org.jboss.jms.client.delegate.ClientClusteredConnectionFactoryDelegate.createConnectionDelegate(ClientClusteredConnectionFactoryDelegate.java)
	at org.jboss.jms.client.JBossConnectionFactory.createConnectionInternal(JBossConnectionFactory.java:205)
	at org.jboss.jms.client.JBossConnectionFactory.createConnection(JBossConnectionFactory.java:87)
	at org.jboss.jms.client.JBossConnectionFactory.createConnection(JBossConnectionFactory.java:82)
	at com.atosorigin.ceps.common.config.CepsJmsSender.sendCepsMessage(CepsJmsSender.java:79)
	at com.atosorigin.ceps.test.multithreading.TestMultithreading_Internal_SingleGraph.submitAcquisition(TestMultithreading_Internal_SingleGraph.java:255)
	at com.atosorigin.ceps.test.multithreading.TestMultithreading_Internal_SingleGraph.proceedAcquisition(TestMultithreading_Internal_SingleGraph.java:237)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
	at java.lang.reflect.Method.invoke(Method.java:597)
	at org.junit.internal.runners.TestMethod.invoke(TestMethod.java:59)
	at org.junit.internal.runners.MethodRoadie.runTestMethod(MethodRoadie.java:98)
	at org.junit.internal.runners.MethodRoadie$2.run(MethodRoadie.java:79)
	at org.junit.internal.runners.MethodRoadie.runBeforesThenTestThenAfters(MethodRoadie.java:87)
	at org.junit.internal.runners.MethodRoadie.runTest(MethodRoadie.java:77)
	at org.junit.internal.runners.MethodRoadie.run(MethodRoadie.java:42)
	at org.junit.internal.runners.JUnit4ClassRunner.invokeTestMethod(JUnit4ClassRunner.java:88)
	at org.junit.internal.runners.JUnit4ClassRunner.runMethods(JUnit4ClassRunner.java:51)
	at com.atosorigin.ceps.utils.junit.ParameterizedRunner$TestClassRunnerForParameters.run(ParameterizedRunner.java:123)
	at org.junit.internal.runners.CompositeRunner.runChildren(CompositeRunner.java:33)
	at com.atosorigin.ceps.utils.junit.ParameterizedRunner.access$000(ParameterizedRunner.java:28)
	at com.atosorigin.ceps.utils.junit.ParameterizedRunner$1.run(ParameterizedRunner.java:76)
	at org.junit.internal.runners.ClassRoadie.runUnprotected(ClassRoadie.java:27)
	at org.junit.internal.runners.ClassRoadie.runProtected(ClassRoadie.java:37)
	at com.atosorigin.ceps.utils.junit.ParameterizedRunner.run(ParameterizedRunner.java:72)
	at org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:45)
	at org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
	at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:460)
	at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:673)
	at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:386)
	at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:196)
Caused by: org.jboss.remoting.CannotConnectException: Can not get connection to server. Problem establishing socket connection for InvokerLocator [bisocket://127.0.0.1:4457/?JBM_clientMaxPoolSize=200&clientLeasePeriod=10000&clientSocketClass=org.jboss.jms.client.remoting.ClientSocketWrapper&connectionWait=10&dataType=jms&marshaller=org.jboss.jms.wireformat.JMSWireFormat&numberOfCallRetries=1&pingFrequency=214748364&pingWindowFactor=10&socket.check_connection=false&stopLeaseOnFailure=true&timeout=0&unmarshaller=org.jboss.jms.wireformat.JMSWireFormat&validatorPingPeriod=10000&validatorPingTimeout=5000]
	at org.jboss.remoting.transport.socket.MicroSocketClientInvoker.transport(MicroSocketClientInvoker.java:771)
	at org.jboss.remoting.transport.bisocket.BisocketClientInvoker.transport(BisocketClientInvoker.java:423)
	at org.jboss.remoting.MicroRemoteClientInvoker.invoke(MicroRemoteClientInvoker.java:160)
	at org.jboss.remoting.MicroRemoteClientInvoker.establishLease(MicroRemoteClientInvoker.java:452)
	at org.jboss.remoting.Client.setupClientLease(Client.java:1699)
	at org.jboss.remoting.Client.connect(Client.java:1599)
	at org.jboss.remoting.Client.connect(Client.java:498)
	at org.jboss.jms.client.remoting.JMSRemotingConnection$1.run(JMSRemotingConnection.java:354)
	at java.security.AccessController.doPrivileged(Native Method)
	at org.jboss.jms.client.remoting.JMSRemotingConnection.start(JMSRemotingConnection.java:350)
	at org.jboss.jms.client.delegate.ClientConnectionFactoryDelegate.org$jboss$jms$client$delegate$ClientConnectionFactoryDelegate$createConnectionDelegate$aop(ClientConnectionFactoryDelegate.java:158)
	... 44 more
Caused by: java.net.ConnectException: Connection refused: connect
	at java.net.PlainSocketImpl.socketConnect(Native Method)
	at java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:333)
	at java.net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:195)
	at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:182)
	at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:366)
	at java.net.Socket.connect(Socket.java:519)
	at org.jboss.remoting.util.SecurityUtility.connect(SecurityUtility.java:1037)
	at org.jboss.remoting.transport.socket.SocketClientInvoker.createSocket(SocketClientInvoker.java:203)
	at org.jboss.remoting.transport.bisocket.BisocketClientInvoker.createSocket(BisocketClientInvoker.java:430)
	at org.jboss.remoting.transport.socket.MicroSocketClientInvoker.getConnection(MicroSocketClientInvoker.java:1084)
	at org.jboss.remoting.transport.socket.MicroSocketClientInvoker.transport(MicroSocketClientInvoker.java:757)
	... 54 more

et dans la console Jboss du deuxième serveur (qui lui marche toujours), j'ai ces messages d'erreurs:

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
19:14:39,734 ERROR [ClientConsumer] Failed to send changeRate message
org.jboss.jms.exception.MessagingNetworkFailureException
        at org.jboss.jms.client.delegate.DelegateSupport.handleThrowable(DelegateSupport.java:240)
        at org.jboss.jms.client.delegate.DelegateSupport.doInvoke(DelegateSupport.java:205)
        at org.jboss.jms.client.delegate.DelegateSupport.doInvoke(DelegateSupport.java:160)
        at org.jboss.jms.client.delegate.ClientConsumerDelegate.org$jboss$jms$client$delegate$ClientConsumerDelegate$changeRa
te$aop(ClientConsumerDelegate.java:138)
        at org.jboss.jms.client.delegate.ClientConsumerDelegate$changeRate_N952316153687074823.invokeTarget(ClientConsumerDel
egate$changeRate_N952316153687074823.java)
        at org.jboss.aop.joinpoint.MethodInvocation.invokeNext(MethodInvocation.java:111)
        at org.jboss.jms.client.container.FailoverValveInterceptor.invoke(FailoverValveInterceptor.java:92)
        at org.jboss.aop.advice.PerInstanceInterceptor.invoke(PerInstanceInterceptor.java:86)
        at org.jboss.aop.joinpoint.MethodInvocation.invokeNext(MethodInvocation.java:102)
        at org.jboss.jms.client.container.ClosedInterceptor.invoke(ClosedInterceptor.java:170)
        at org.jboss.aop.advice.PerInstanceInterceptor.invoke(PerInstanceInterceptor.java:86)
        at org.jboss.aop.joinpoint.MethodInvocation.invokeNext(MethodInvocation.java:102)
        at org.jboss.jms.client.delegate.ClientConsumerDelegate.changeRate(ClientConsumerDelegate.java)
        at org.jboss.jms.client.container.ClientConsumer.sendChangeRateMessage(ClientConsumer.java:754)
        at org.jboss.jms.client.container.ClientConsumer.pause(ClientConsumer.java:669)
        at org.jboss.messaging.core.impl.clusterconnection.MessageSucker.setConsuming(MessageSucker.java:216)
        at org.jboss.messaging.core.impl.clusterconnection.MessageSucker.stop(MessageSucker.java:150)
        at org.jboss.messaging.core.impl.clusterconnection.ClusterConnectionManager.removeSucker(ClusterConnectionManager.jav
a:509)
        at org.jboss.messaging.core.impl.clusterconnection.ClusterConnectionManager.notify(ClusterConnectionManager.java:367)
 
        at org.jboss.messaging.core.impl.DefaultClusterNotifier.sendNotification(DefaultClusterNotifier.java:72)
        at org.jboss.messaging.core.impl.postoffice.MessagingPostOffice.removeBindingInMemory(MessagingPostOffice.java:2356)
        at org.jboss.messaging.core.impl.postoffice.MessagingPostOffice.performFailover(MessagingPostOffice.java:2995)
        at org.jboss.messaging.core.impl.postoffice.MessagingPostOffice.nodesLeft(MessagingPostOffice.java:962)
        at org.jboss.messaging.core.impl.postoffice.GroupMember$ControlMembershipListener.viewAccepted(GroupMember.java:508)
        at org.jgroups.blocks.MessageDispatcher$ProtocolAdapter.handleUpEvent(MessageDispatcher.java:733)
        at org.jgroups.blocks.MessageDispatcher$ProtocolAdapter.up(MessageDispatcher.java:776)
        at org.jgroups.JChannel.up(JChannel.java:1274)
        at org.jgroups.stack.ProtocolStack.up(ProtocolStack.java:462)
        at org.jgroups.protocols.pbcast.FLUSH.up(FLUSH.java:391)
        at org.jgroups.protocols.pbcast.STATE_TRANSFER.up(STATE_TRANSFER.java:144)
        at org.jgroups.protocols.FRAG2.up(FRAG2.java:192)
        at org.jgroups.protocols.FC.up(FC.java:487)
        at org.jgroups.protocols.pbcast.GMS.installView(GMS.java:546)
        at org.jgroups.protocols.pbcast.CoordGmsImpl.handleViewChange(CoordGmsImpl.java:460)
        at org.jgroups.protocols.pbcast.GMS.up(GMS.java:720)
        at org.jgroups.protocols.VIEW_SYNC.up(VIEW_SYNC.java:192)
        at org.jgroups.protocols.pbcast.STABLE.up(STABLE.java:233)
        at org.jgroups.protocols.UNICAST.up(UNICAST.java:299)
        at org.jgroups.protocols.pbcast.NAKACK.handleMessage(NAKACK.java:873)
        at org.jgroups.protocols.pbcast.NAKACK.up(NAKACK.java:705)
        at org.jgroups.protocols.BARRIER.up(BARRIER.java:136)
        at org.jgroups.protocols.VERIFY_SUSPECT.up(VERIFY_SUSPECT.java:167)
        at org.jgroups.protocols.FD.up(FD.java:284)
        at org.jgroups.protocols.FD_SOCK.up(FD_SOCK.java:308)
        at org.jgroups.protocols.MERGE2.up(MERGE2.java:144)
        at org.jgroups.protocols.Discovery.up(Discovery.java:263)
        at org.jgroups.protocols.PING.up(PING.java:270)
        at org.jgroups.protocols.TP$ProtocolAdapter.up(TP.java:2319)
        at org.jgroups.protocols.TP.passMessageUp(TP.java:1253)
        at org.jgroups.protocols.TP.access$100(TP.java:49)
        at org.jgroups.protocols.TP$1.run(TP.java:1180)
        at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
        at java.lang.Thread.run(Thread.java:619)
Caused by: org.jboss.remoting.CannotConnectException: Can not get connection to server. Problem establishing socket connectio
n for InvokerLocator [bisocket://127.0.0.1:4457/?JBM_clientMaxPoolSize=200&clientLeasePeriod=10000&clientSocketClass=org.jbos
s.jms.client.remoting.ClientSocketWrapper&connectionWait=10&dataType=jms&marshaller=org.jboss.jms.wireformat.JMSWireFormat&nu
mberOfCallRetries=1&pingFrequency=214748364&pingWindowFactor=10&socket.check_connection=false&stopLeaseOnFailure=true&timeout
=0&unmarshaller=org.jboss.jms.wireformat.JMSWireFormat&validatorPingPeriod=10000&validatorPingTimeout=5000]
        at org.jboss.remoting.transport.socket.MicroSocketClientInvoker.transport(MicroSocketClientInvoker.java:771)
        at org.jboss.remoting.transport.bisocket.BisocketClientInvoker.transport(BisocketClientInvoker.java:423)
        at org.jboss.remoting.MicroRemoteClientInvoker.invoke(MicroRemoteClientInvoker.java:160)
        at org.jboss.remoting.Client.invoke(Client.java:1708)
        at org.jboss.remoting.Client.invoke(Client.java:612)
        at org.jboss.remoting.Client.invoke(Client.java:600)
        at org.jboss.jms.client.delegate.DelegateSupport.doInvoke(DelegateSupport.java:189)
        ... 52 more
Caused by: java.net.ConnectException: Connection refused: connect
        at java.net.PlainSocketImpl.socketConnect(Native Method)
        at java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:333)
        at java.net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:195)
        at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:182)
        at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:366)
        at java.net.Socket.connect(Socket.java:519)
        at org.jboss.remoting.util.SecurityUtility.connect(SecurityUtility.java:1037)
        at org.jboss.remoting.transport.socket.SocketClientInvoker.createSocket(SocketClientInvoker.java:203)
        at org.jboss.remoting.transport.bisocket.BisocketClientInvoker.createSocket(BisocketClientInvoker.java:430)
        at org.jboss.remoting.transport.socket.MicroSocketClientInvoker.getConnection(MicroSocketClientInvoker.java:1084)
        at org.jboss.remoting.transport.socket.MicroSocketClientInvoker.transport(MicroSocketClientInvoker.java:757)
        ... 58 more

Les conditions de test: je lance un test Junit via Eclipse. Ce test comporte l'envoi en boucle de messages JMS. J'ai deux serveurs Jboss lancés sur le même cluster. J'en crash un. Je m'attends à ce que le test continue, à ce que le deuxième serveur reprenne le travail du premier.
Pour le HAJNDI, j'ai mis ces lignes de configuration dans l'application déployée dans Jboss (mes deux Jboss sont sur la même machine pour le développement):

Code:

1
2
3
4
5
6
7
Properties p = new Properties();
p.put(Context.INITIAL_CONTEXT_FACTORY, "org.jnp.interfaces.NamingContextFactory");
p.put(Context.URL_PKG_PREFIXES, "jboss.naming:org.jnp.interfaces");
// HA-JNDI is registered under the partition name passed to JBoss via -g
String partitionName = System.getProperty("jboss.partition.name", "DefaultPartition");
p.put("jnp.partitionName", partitionName);
return new InitialContext(p);

Mes tests depuis Eclipse utilisent la propriété:
java.naming.provider.url=localhost:1100,localhost:1100

J'ai Jboss 5.0.1 et MySQL (j'ai bien mis le jar mysql-connector).

As-tu bien respecté la procédure de clustering de JBoss Messaging ? Je pense en particulier au ServerPeerID et au suckerPassword.

Je ne comprend pas l'intérêt de faire du failover sur la même machine. Peux-tu nous en dire plus ?

Le failover sur une même machine, c'est juste pour les tests. Je n'ai pas pour le moment d'autre machines disponible mais ce sera bientôt le cas.

Concernant le suckerPassword et les ServerPeerID, j'ai bien défini un suckerPassword, et j'ai bien défini des ServerPeerID différents.