jms - 远程服务器上的 Spring Access JMS
问题描述
我有一个 Maven Spring 4 应用程序,我在http://localhost:9292的本地 Jetty 服务器上运行。我还有一个运行在http://localhost:9990的 JBoss EAP 服务器,我在上面创建了一个 JMS 主题。
但我不知道如何从我的 Spring 应用程序访问 JMS 元素。
在这篇文章的最后是来自 JBoss EAP 7 配置文件standalone.xml 的一些元素,(消息部分)
这就是我尝试至少从我的 Spring 应用程序访问连接工厂的方法
final Properties env = new Properties();
env.put(Context.PROVIDER_URL, "remote://http://localhost:9990");
Context context = new InitialContext(env);
ConnectionFactory cf = (ConnectionFactory) context.lookup("RemoteConnectionFactory");
但我有一个错误:
javax.naming.NameNotFoundException; 剩余名称“远程连接工厂”
你知道我可以如何使用远程 JMS 元素,如 ConnectionFactory、Topic、...
在此先感谢您的帮助
<subsystem xmlns="urn:jboss:domain:messaging-activemq:1.0">
<server name="default">
<cluster password="${jboss.messaging.cluster.password:CHANGE ME!!}"/>
<security-setting name="#">
<role name="guest" delete-non-durable-queue="true" create-non-durable-queue="true" consume="true" send="true"/>
</security-setting>
<address-setting name="#" redistribution-delay="1000" message-counter-history-day-limit="10" page-size-bytes="2097152" max-size-bytes="10485760" expiry-address="jms.queue.ExpiryQueue" dead-letter-address="jms.queue.DLQ"/>
<http-connector name="http-connector" endpoint="http-acceptor" socket-binding="http"/>
<http-connector name="http-connector-throughput" endpoint="http-acceptor-throughput" socket-binding="http">
<param name="batch-delay" value="50"/>
</http-connector>
<in-vm-connector name="in-vm" server-id="0"/>
<http-acceptor name="http-acceptor" http-listener="default"/>
<http-acceptor name="http-acceptor-throughput" http-listener="default">
<param name="batch-delay" value="50"/>
<param name="direct-deliver" value="false"/>
</http-acceptor>
<in-vm-acceptor name="in-vm" server-id="0"/>
<broadcast-group name="bg-group1" connectors="http-connector" jgroups-channel="activemq-cluster"/>
<discovery-group name="dg-group1" jgroups-channel="activemq-cluster"/>
<cluster-connection name="my-cluster" discovery-group="dg-group1" connector-name="http-connector" address="jms"/>
<jms-queue name="ExpiryQueue" entries="java:/jms/queue/ExpiryQueue"/>
<jms-queue name="DLQ" entries="java:/jms/queue/DLQ"/>
<jms-topic name="my_topic" entries="java:/jms/topic/my_topic"/>
<connection-factory name="InVmConnectionFactory" entries="java:/ConnectionFactory" connectors="in-vm"/>
<connection-factory name="RemoteConnectionFactory" reconnect-attempts="-1" block-on-acknowledge="true" ha="true" entries="java:jboss/exported/jms/RemoteConnectionFactory" connectors="http-connector"/>
<pooled-connection-factory name="activemq-ra" transaction="xa" entries="java:/JmsXA java:jboss/DefaultJMSConnectionFactory" connectors="in-vm"/>
</server>
</subsystem>
套接字绑定部分:
<socket-binding-group name="standard-sockets" default-interface="public" port-offset="${jboss.socket.binding.port-offset:0}">
<socket-binding name="management-http" interface="management" port="${jboss.management.http.port:9990}"/>
<socket-binding name="management-https" interface="management" port="${jboss.management.https.port:9993}"/>
<socket-binding name="ajp" port="${jboss.ajp.port:8009}"/>
<socket-binding name="http" port="${jboss.http.port:8080}"/>
<socket-binding name="https" port="${jboss.https.port:8443}"/>
<socket-binding name="iiop" interface="unsecure" port="3528"/>
<socket-binding name="iiop-ssl" interface="unsecure" port="3529"/>
<socket-binding name="jgroups-mping" interface="private" port="0" multicast-address="${jboss.default.multicast.address:230.0.0.4}" multicast-port="45700"/>
<socket-binding name="jgroups-tcp" interface="private" port="7600"/>
<socket-binding name="jgroups-tcp-fd" interface="private" port="57600"/>
<socket-binding name="jgroups-udp" interface="private" port="55200" multicast-address="${jboss.default.multicast.address:230.0.0.4}" multicast-port="45688"/>
<socket-binding name="jgroups-udp-fd" interface="private" port="54200"/>
<socket-binding name="modcluster" port="0" multicast-address="224.0.1.105" multicast-port="23364"/>
<socket-binding name="txn-recovery-environment" port="4712"/>
<socket-binding name="txn-status-manager" port="4713"/>
<outbound-socket-binding name="mail-smtp">
<remote-destination host="localhost" port="25"/>
</outbound-socket-binding>
</socket-binding-group>
解决方案
我看到一些错误的地方:
我建议指定初始上下文工厂,例如:
env.put(Context.INITIAL_CONTEXT_FACTORY, org.jboss.naming.remote.client.InitialContextFactory.class.getName());
您的 JNDI 查找应
http-remoting://localhost:8080
默认使用。java:jboss/exported/
远程客户端根据服务器端配置中的内容查找 JNDI 条目。对于您的RemoteConnectionFactory
连接工厂,您应该jms/RemoteConnectionFactory
在查找中使用,例如:ConnectionFactory cf = (ConnectionFactory) context.lookup("jms/RemoteConnectionFactory");
如果您想
my_topic
从远程客户端查找主题,您需要添加一个远程公开 JNDI 名称的条目,例如:<jms-topic name="my_topic" entries="java:/jms/topic/my_topic java:jboss/exported/jms/topic/my_topic"/>
推荐阅读
- amazon-web-services - AWS Lambda 函数:无法获取秘密 arn:aws:secretsmanager
- c# - 无法在 C# .Net Framework 中调用带有参数的 HttpGet 方法
- android - 无法到达 EditText 中的 EditorAction
- python - 使用 plotly scatter matrix API 添加图例?
- javascript - 在Javascript中将数组推入多维数组
- raspberry-pi - 如何在 Motion 中的 on_event_end 后暂停
- django - Celery-Django 博客 Grok 模式
- php - 使用关系不同名称的 Laravel 数据表服务
- jenkins - 如果我们在管道中有 1 到 6 个作业并且想要执行第 6 个作业,我们该怎么做
- r - 在 r 中读取数据时出现持续错误