远程 JMS 通信正常，EJB 通信失败

【问题标题】：Remote JMS communication works, EJB communication fails远程 JMS 通信正常，EJB 通信失败
【发布时间】：2015-09-07 02:33:16
【问题描述】：

我目前正在向自己介绍 Java EE，尤其是如何使用 EJB 和 JMS。

问题简述

我在互联网上有一个本地客户端和一个远程服务器。 JMS 通信工作正常，EJB 通信不行。两种通信都在我的本地网络中成功。

更详细的问题

我正在使用 Maven 构建：

  • 一个包含几个无状态远程 EJB 和一个 MDB 的 EAR
  • 一个桌面客户端，包括由 Maven 生成的 EJB 客户端 JAR，用于与服务器通信。

我正在使用 WildFly 应用程序服务器来部署 EAR。根据服务器日志，EJB 已成功导出。所有流量均基于http-remoting。 Undertow 根据需要根据嗅探到的流量切换协议。

我们以客户端登录为例。登录API调用基于远程EJB通信，同时发送JMS消息。

如果我在本地计算机上从 Eclipse 运行客户端和服务器，登录工作正常并且 JMS 消息得到正确处理。如果我在同一网络中的另一台机器上运行客户端，同样适用。如果我在本地网络中运行客户端，但在 Internet 中运行服务器，则 EJB 通信失败并且 JMS 消息仍然可以正确处理。

这是为什么呢？

日志内容

没有调用远程 EJB 的登录方法，没有日志。我已将log4j.logger.org.jboss.ejb.client=TRACE 添加到log4j.properties。这是客户端在 API 调用失败时的日志：

2015-06-21 16:47:49 [GS Desktop Init Thread] DEBUG PropertiesBasedEJBClientConfiguration:242 - endpoint.create.options. has the following options {}
2015-06-21 16:47:49 [GS Desktop Init Thread] TRACE PropertiesBasedEJBClientConfiguration:272 - Options {} have been merged with defaults {org.xnio.Options.THREAD_DAEMON=>true} to form {org.xnio.Options.THREAD_DAEMON=>true}
2015-06-21 16:47:49 [GS Desktop Init Thread] DEBUG PropertiesBasedEJBClientConfiguration:242 - remote.connectionprovider.create.options. has the following options {org.xnio.Options.SSL_ENABLED=>false}
2015-06-21 16:47:49 [GS Desktop Init Thread] TRACE PropertiesBasedEJBClientConfiguration:272 - Options {org.xnio.Options.SSL_ENABLED=>false} have been merged with defaults {} to form {org.xnio.Options.SSL_ENABLED=>false}
2015-06-21 16:47:49 [GS Desktop Init Thread] DEBUG PropertiesBasedEJBClientConfiguration:242 - remote.connection.default.connect.options. has the following options {org.xnio.Options.SASL_DISALLOWED_MECHANISMS=>[JBOSS-LOCAL-USER],org.xnio.Options.SASL_POLICY_NOANONYMOUS=>false}
2015-06-21 16:47:49 [GS Desktop Init Thread] TRACE PropertiesBasedEJBClientConfiguration:272 - Options {org.xnio.Options.SASL_DISALLOWED_MECHANISMS=>[JBOSS-LOCAL-USER],org.xnio.Options.SASL_POLICY_NOANONYMOUS=>false} have been merged with defaults {} to form {org.xnio.Options.SASL_DISALLOWED_MECHANISMS=>[JBOSS-LOCAL-USER],org.xnio.Options.SASL_POLICY_NOANONYMOUS=>false}
2015-06-21 16:47:49 [GS Desktop Init Thread] DEBUG PropertiesBasedEJBClientConfiguration:242 - remote.connection.default.channel.options. has the following options {}
2015-06-21 16:47:49 [GS Desktop Init Thread] DEBUG PropertiesBasedEJBClientConfiguration:490 - Connection org.jboss.ejb.client.PropertiesBasedEJBClientConfiguration$RemotingConnectionConfigurationImpl@33f49f38 successfully created for connection named default
2015-06-21 16:47:49 [GS Desktop Init Thread] DEBUG PropertiesBasedEJBClientConfiguration:295 - No clusters configured in properties
2015-06-21 16:47:49 [GS Desktop Init Thread] DEBUG EJBClientPropertiesLoader:100 - Looking for jboss-ejb-client.properties using classloader sun.misc.Launcher$AppClassLoader@58644d46
2015-06-21 16:47:49 [GS Desktop Init Thread] INFO  client:45 - JBoss EJB Client version 2.1.1.Final
...
2015-06-21 16:47:51 [Remoting "config-based-ejb-client-endpoint" task-4] DEBUG RemotingConnectionEJBReceiver:191 - Channel Channel ID eb5d763d (outbound) of Remoting connection 25bff644 to euve1234.vserver.de/84.46.96.86:8080 opened for context EJBReceiverContext{clientContext=org.jboss.ejb.client.EJBClientContext@3baeae68, receiver=Remoting connection EJB receiver [connection=org.jboss.ejb.client.remoting.ConnectionPool$PooledConnection@3f310404,channel=jboss.ejb,nodename=euve1234]} Waiting for version handshake message from server
2015-06-21 16:47:51 [Remoting "config-based-ejb-client-endpoint" task-5] INFO  remoting:103 - EJBCLIENT000017: Received server version 2 and marshalling strategies [river]
2015-06-21 16:47:51 [GS Desktop Thread 0] INFO  remoting:218 - EJBCLIENT000013: Successful version handshake completed for receiver context EJBReceiverContext{clientContext=org.jboss.ejb.client.EJBClientContext@3baeae68, receiver=Remoting connection EJB receiver [connection=org.jboss.ejb.client.remoting.ConnectionPool$PooledConnection@3f310404,channel=jboss.ejb,nodename=euve1234]} on channel Channel ID eb5d763d (outbound) of Remoting connection 25bff644 to euve1234.vserver.de/84.46.96.86:8080
2015-06-21 16:47:51 [Remoting "config-based-ejb-client-endpoint" task-6] TRACE ChannelAssociation:375 - Received message with header 0x8
2015-06-21 16:47:51 [Remoting "config-based-ejb-client-endpoint" task-6] DEBUG RemotingConnectionEJBReceiver:763 - Received module availability report for 11 modules
2015-06-21 16:47:51 [Remoting "config-based-ejb-client-endpoint" task-6] DEBUG RemotingConnectionEJBReceiver:765 - Registering module EJBModuleIdentifier{appName='GSServerEAR-0.0.1', moduleName='GSAuthManagerEjb-0.0.1', distinctName=''} availability for receiver context EJBReceiverContext{clientContext=org.jboss.ejb.client.EJBClientContext@3baeae68, receiver=Remoting connection EJB receiver [connection=org.jboss.ejb.client.remoting.ConnectionPool$PooledConnection@3f310404,channel=jboss.ejb,nodename=euve1234]}
2015-06-21 16:47:51 [Remoting "config-based-ejb-client-endpoint" task-6] DEBUG RemotingConnectionEJBReceiver:765 - Registering module EJBModuleIdentifier{appName='GSServerEAR-0.0.1', moduleName='GSNotificationManagerEjb-0.0.1', distinctName=''} availability for receiver context EJBReceiverContext{clientContext=org.jboss.ejb.client.EJBClientContext@3baeae68, receiver=Remoting connection EJB receiver [connection=org.jboss.ejb.client.remoting.ConnectionPool$PooledConnection@3f310404,channel=jboss.ejb,nodename=euve1234]}
...
2015-06-21 16:47:51 [Remoting "config-based-ejb-client-endpoint" task-6] DEBUG RemotingConnectionEJBReceiver:765 - Registering module EJBModuleIdentifier{appName='GSServerEAR-0.0.1', moduleName='GSServerEAR-0.0.1', distinctName=''} availability for receiver context EJBReceiverContext{clientContext=org.jboss.ejb.client.EJBClientContext@3baeae68, receiver=Remoting connection EJB receiver [connection=org.jboss.ejb.client.remoting.ConnectionPool$PooledConnection@3f310404,channel=jboss.ejb,nodename=euve1234]}
2015-06-21 16:47:51 [GS Desktop Thread 0] DEBUG ConfigBasedEJBClientContextSelector:174 - Registered 1 remoting EJB receivers for EJB client context org.jboss.ejb.client.EJBClientContext@3baeae68
...
2015-06-21 16:47:51 [JavaFX Application Thread] WARN  GsTask:38 - API call background task failed
java.lang.IllegalStateException: EJBCLIENT000025: No EJB receiver available for handling [appName:GSServerEAR, moduleName:GSAuthManagerEjb-0.0.1, distinctName:] combination for invocation context org.jboss.ejb.client.EJBClientInvocationContext@63dd58c4
    at org.jboss.ejb.client.EJBClientContext.requireEJBReceiver(EJBClientContext.java:774)
    at org.jboss.ejb.client.ReceiverInterceptor.handleInvocation(ReceiverInterceptor.java:116)
    at org.jboss.ejb.client.EJBClientInvocationContext.sendRequest(EJBClientInvocationContext.java:186)
    at org.jboss.ejb.client.EJBInvocationHandler.sendRequestWithPossibleRetries(EJBInvocationHandler.java:255)
    at org.jboss.ejb.client.EJBInvocationHandler.doInvoke(EJBInvocationHandler.java:200)
    at org.jboss.ejb.client.EJBInvocationHandler.doInvoke(EJBInvocationHandler.java:183)
    at org.jboss.ejb.client.EJBInvocationHandler.invoke(EJBInvocationHandler.java:146)
    at com.sun.proxy.$Proxy7.createSession(Unknown Source)
    ...

我的一些想法

问题可能是由以下原因引起的

  1. IP 无效？
    • 没有。移动服务器后，我更新了standalone.xml 配置，并通过观察所有机器上的网络流量来确保接收到所有呼叫。 JMS 有效。
  2. WildFly 安全设置，例如关于安全领域配置？
    • 没有。登录在本地工作。这些设置在移动服务器后应该是有效的。 JMS 和 EJB 都使用同一个 WildFly 应用程序用户。 JMS 有效。
  3. 可能是网络/路由问题，因为 EJB 基于 RMI，还是某种防火墙问题？
    • 可能，但 JMS 可以工作。我还没有真正习惯JMS，但它不是基于RMI吗？我发送javax.jms.ObjectMessages。 Session.createObjectMessage(Serializable object) 需要 Serializable，这就是为什么我建议我们在这里也有 RMI。
  4. 在本地，WildFly 在 Windows 7 上运行。在远程，Wildfly 在 Ubuntu 上运行。我为此尝试了 Ubuntu 10/12/14。
    • 关于 Java 和 WildFly：它们与平台无关。一次编写，到处运行。我认为问题不太可能是由底层操作系统引起的。我已验证流量和 JMS 工作正常。

如果我错了，请纠正我。

补充说明

  • 我知道这么久以来我提供的信息很少，因为我不想搞砸我的问题。如果您需要更多信息，请随时询问。这也适用于代码。
  • 我正在使用 Java SE 8 / Java EE 7。关于 WildFly：我测试了 8.1.0.Final、8.2.0.Final 和 9.0.0.Beta2。
  • 请不要简单地参考在线示例。我已经为此工作了好几天，请记住，local 通信已经正常工作了。

我非常感谢您对此的任何想法和想法，因为我真的陷入了困境。非常感谢。

更新 1：EJB 实现、客户端上下文创建和 EJB 查找

服务器： 

@Remote
public interface GsAuthManager {

    GsClientSession createSession(String username, String password);

}

@Stateless
public class GsAuthManagerBean implements GsAuthManager {

    @Override
    public GsClientSession createSession(String username, String password) {
        // ...
    }

}

WildFly 日志：

java:jboss/exported/GSServerEAR/GSAuthManagerEjb-0.0.1/GsAuthManagerBean!de.genesys.server.ejb.auth.GsAuthManager

客户：

static void initEjbClient(String serverHostname, String username, String password) {
    final Properties ejbClientProps = new Properties();
    ejbClientProps.put("remote.connections", "default");
    ejbClientProps.put("remote.connection.default.port", "8080");
    ejbClientProps.put("remote.connection.default.host", serverHostname);
    ejbClientProps.put("remote.connection.default.username", username);
    ejbClientProps.put("remote.connection.default.password", password);
    ejbClientProps.put("remote.connection.default.connect.options.org.xnio.Options.SASL_POLICY_NOANONYMOUS", "false");
    ejbClientProps.put("remote.connection.default.connect.options.org.xnio.Options.SASL_DISALLOWED_MECHANISMS", "JBOSS-LOCAL-USER");
    ejbClientProps.put("remote.connectionprovider.create.options.org.xnio.Options.SSL_ENABLED", "false");

    EJBClientConfiguration clientConfig = new PropertiesBasedEJBClientConfiguration(ejbClientProps);
    ContextSelector<EJBClientContext> selector = new ConfigBasedEJBClientContextSelector(clientConfig);
    EJBClientContext.setSelector(selector);
}

static GsAuthManager initEjbProxy(String serverHostname, String username, String password) throws NamingException{
    Properties props = new Properties();
    props.put("jboss.naming.client.ejb.context", true);
    props.put("jboss.naming.client.connect.options.org.xnio.Options.SASL_POLICY_NOPLAINTEXT", "false");
    props.put(Context.URL_PKG_PREFIXES, "org.jboss.ejb.client.naming");
    props.put(Context.INITIAL_CONTEXT_FACTORY, "org.jboss.naming.remote.client.InitialContextFactory");
    props.put(Context.PROVIDER_URL, "http-remoting://" + serverHostname + ":8080");
    props.put(Context.SECURITY_PRINCIPAL, username);
    props.put(Context.SECURITY_CREDENTIALS, password);
    InitialContext context = new InitialContext(props); // Stripped down, original code keeps a strong reference and closes context on program termination 
    return (GsAuthManager) context.lookup("ejb:GSServerEAR/GSAuthManagerEjb-0.0.1/GsAuthManagerBean!de.genesys.server.ejb.auth.GsAuthManager");
}

【问题讨论】：

  • 您是否有可以分享的代码示例，展示您如何连接和查找 bean？该错误似乎表明您正在查找的任何 bean 都没有实现。如果您也可以包含您的服务器端实现（精简）。
  • 谢谢@JohnAment，我已经更新了我的问题。您能否澄清一下：是否绝对可以通过 Internet 调用 EJB？我还没有看到确保这一点的示例。
  • 某处你有appName='GSServerEAR-0.0.1'，当你的异常发生时：appName:GSServerEAR。所以我想，你的 EAR 文件的运行时（当你部署它时）包含版本，它不应该。
  • 嗨@AndreiI，感谢您的评论。 Eclipse IDE 部署的 EAR 命名为 GSServerEAR.ear，而 Maven 目标命名为 GSServerEAR-0.0.1.ear。重命名它可以解决问题。我不敢相信我已经花了好几天的时间...请写一个答案，我将不胜感激地接受它:) 感谢您的帮助！

标签： ejb jms wildfly java-ee-7


【解决方案1】：

在您部署appName='GSServerEAR-0.0.1' 的日志中，但发生异常时：appName:GSServerEAR。所以我想，你的 EAR 文件的运行时（当你部署它时）包含版本，它不应该。

【讨论】：

    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2010-09-27
    • 1970-01-01
    • 2017-07-31
    • 2021-12-13
    • 2012-06-07
    • 1970-01-01
    相关资源
    最近更新 更多
    热门标签
    Java Python linux javascript Mysql C# Docker 算法 前端 SpringBoot Redis Vue spring 设计模式 .net core .net kubernetes c++ 数据库 数据结构 大数据 js 机器学习 微服务 Android Go 程序员 面试 JVM ASP.net core 云原生 人工智能 后端 PHP git CSS golang k8s Nginx Django mybatis 深度学习 多线程 React 架构 devops 爬虫 云计算 Spring Boot LeetCode