首页 \ 问答 \ ActiveMQ ConnectionFailedException(ActiveMQ ConnectionFailedException)

ActiveMQ ConnectionFailedException(ActiveMQ ConnectionFailedException)

我正在尝试使用JMS向ActiveMQ发布消息,

String loginID="admin";
String loginPswd="admin";
String hostName="svful0000283np.nyzdc.local";
String channel="http";
String portNumber="8161";
String hostUrl=channel + "://" + hostName + ":" + portNumber;
String inputQueue="com.nbn.telecom.sap.ManageSQ";
String outputQueue="com.nbn.telecom.sap.ManageSQ.response";

String messageText="my text";                              
ConnectionFactory factory = new ActiveMQConnectionFactory(loginID, loginPswd,hostUrl);         
Connection connection = factory.createConnection();   
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

上面的最后一条陈述给出了以下错误信息 -

   org.apache.activemq.ConnectionFailedException: The JMS connection has failed:            Failed to perform GET on: http://svful0000283np.nyzdc.local:8161 Reason: null

可能是错误的原因是什么? 感谢您的帮助


I am trying to post a message to ActiveMQ using JMS,

String loginID="admin";
String loginPswd="admin";
String hostName="svful0000283np.nyzdc.local";
String channel="http";
String portNumber="8161";
String hostUrl=channel + "://" + hostName + ":" + portNumber;
String inputQueue="com.nbn.telecom.sap.ManageSQ";
String outputQueue="com.nbn.telecom.sap.ManageSQ.response";

String messageText="my text";                              
ConnectionFactory factory = new ActiveMQConnectionFactory(loginID, loginPswd,hostUrl);         
Connection connection = factory.createConnection();   
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

Last statement in the above gives the below error message -

   org.apache.activemq.ConnectionFailedException: The JMS connection has failed:            Failed to perform GET on: http://svful0000283np.nyzdc.local:8161 Reason: null

What could be the reason for the error? Thanks for your help in advance


原文:https://stackoverflow.com/questions/33317919
更新时间:2020-02-08 08:17

最满意答案

在再次掌握你的问题的同时,我看到8161端口......它是jetty默认端口 .....为其管理提供ActiveMQ管理控制台 .....

您只能使用其消息传递端口进行消息传递.....端口61616,5672,61613,1883,61614分别用于openwire,amqp,stomp,mqtt,ws协议消息.....

那个配置就在这里....在'[ACTIVEMQ_HOME] / conf / activemq.xml '上

          <transportConnectors>
                <!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB -->
                <transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
                <transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
                <transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
                <transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
                <transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
          </transportConnectors>

如果没有冲突,您可以将端口更改为其他数字....

0.0.0.0仅适用于环回ip 127.0.0.1 ...我的意思是只在localhost ....

如果它是unix,则通过ifconfig查找ip替换ip 0.0.0.0,如果是基于Windows或基于DOS,则替换ipconfig ...应该在运行ActiveMQ的机器上完成


While grasping your Question again, I am seeing 8161 port... it is jetty default port..... that provision ActiveMQ Admin Console for its Administration.....

You could only use its messaging ports for messaging..... Port 61616, 5672, 61613, 1883, 61614 for openwire, amqp, stomp, mqtt, ws protocol messaging respectively.....

That config resides right here.... on '[ACTIVEMQ_HOME]/conf/activemq.xml'

          <transportConnectors>
                <!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB -->
                <transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
                <transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
                <transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
                <transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
                <transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
          </transportConnectors>

You could change port to some other number if it doesn't conflicts....

0.0.0.0 works only for loopback ip 127.0.0.1... I mean only at localhost....

Else replace ip 0.0.0.0 by finding ip by ifconfig if it is unix..... else ipconfig if it is Windows or DOS based... that should be done on the machine where you are running ActiveMQ

2015-12-23

相关问答

更多

yum install activemq activemq-client - 没有可用的包activemq(yum install activemq activemq-client - no package activemq available)

对于本教程后的简单安装,您必须为yum启用不同的repos,这可以通过以下方式完成 subscription-manager repos --enable=*repoid* 要获取Repo ID列表,您可以使用: subscription-manager repos --list 在此之后,一切正常。 For a simple installation following the tutorial you have to enable different repos for yum, this ...

ActiveMQ没有启动(ActiveMQ is not starting)

您必须通过命令启动ActiveMQ: activemq-admin.bat start activemq.bat用于管理,这就是你设置参数的原因 You must start ActiveMQ by command: activemq-admin.bat start activemq.bat is for managment, that's why you have set arguments

activemq问题

import javax.jms.Connection; import javax.jms.DeliveryMode; import javax.jms.Destination; import javax.jms.JMSException; import javax.jms.MessageProducer; import javax.jms.Session; import javax.jms.TextMessage; jms.jar ================================ ...

一起使用ActiveMQ和GlassFish(Using ActiveMQ and GlassFish together)

请看这个教程: http : //javadude.wordpress.com/2011/07/21/glassfish-v3-1-running-embedded-activemq-for-jms-part-1/ Please look at this tutorial: http://javadude.wordpress.com/2011/07/21/glassfish-v3-1-running-embedded-activemq-for-jms-part-1/

jmx似乎没有使用activeMQ(jmx doesnt seem to be working with activeMQ)

默认情况下启用远程监控的密码验证。 要禁用它,请在启动JVM时设置以下系统属性:-Dcom.sun.management.jmxremote.authenticate = false,就像在第二次测试中完成的那样但是需要添加系统属性-Dcom.sun.management.jmxremote 尝试将这些jvm param添加到env文件并更新主机ip -Djava.net.preferIPv4Stack = true -Djava.rmi.server.hostname = XXXX UPDATE ...

servicemix中的activemq(activemq in servicemix)

我在<> / etc / org.ops4j.pax.url.mvn文件中包含了属性org.ops4j.pax.url.mvn.repositories的一些repo位置,这使得此连接异常消失了。 注意:我不确定如何添加这些repo,解决了连接问题,但是我希望在属性文件中添加repo位置(如上所述)可能有助于servicemix访问某些API来建立连接。 I included some repo location for property org.ops4j.pax.url.mvn.reposit ...

ActiveMQ ConnectionFailedException(ActiveMQ ConnectionFailedException)

在再次掌握你的问题的同时,我看到8161端口......它是jetty默认端口 .....为其管理提供ActiveMQ管理控制台 ..... 您只能使用其消息传递端口进行消息传递.....端口61616,5672,61613,1883,61614分别用于openwire,amqp,stomp,mqtt,ws协议消息..... 那个配置就在这里....在'[ACTIVEMQ_HOME] / conf / activemq.xml '上 <transportConnectors> ...

了解Apache ActiveMQ(Understanding Apache ActiveMQ)

是的,您可以将主框用作服务器,让消费者/订户在其他框上运行(需要连接到服务器 - 您需要为要建立的连接指定服务器主机名和端口) - 一旦进入在某个地方,客户端可以使用服务器上的消息(主题或队列)。 如果您有一个生产者和一个消费者,您可以考虑使用队列 - 如果您有多个消费者/订阅者,您可以考虑设置消费者将订阅的主题。 需要根据需要将消息插入主题/队列。 您可以在代码中或最好在配置文件中指定服务器信息。 有关拓扑的参考: http : //activemq.apache.org/topologies. ...

如何升级ActiveMQ?(How to Upgrade ActiveMQ?)

这取决于涉及哪些版本。 一般情况下:*安装新版本,复制Kahadb文件*复制conf文件夹*复制您手动安装的任何自定义库,webapps,插件等*检查版本说明“旧”和“新”之间的版本。 它会说明你需要考虑的重大变化。 示例:ObjectMessage安全问题,Java 8需求,JDBC表更改等。 关于conf,“activemq.xml”,您应该仔细检查配置并与新版本进行比较。 有时会引入您想在自定义配置中使用的新功能,配置和默认设置。 如果您使用的是配置OOTB,这很容易,对于经过大量修改的ac ...

ActiveMQ授权(ActiveMQ authorization)

每当我设置ActiveMQ安全性时,我发现最好使用普通的AuthorizationPlugin和通配符来表示所覆盖的目标(这就是为什么使用队列和主题的命名约定非常方便)。 我们的想法是您定义少数用户组并授予他们访问这些目的地的权限。 从用户名分配组的角色由其中一个身份验证插件处理 - JAAS插件对于在LDAP目录中的ActiveMQ配置外部化此信息特别有用。 查看FuseSource的ActiveMQ安全指南 (需要注册)以获取更多信息。 更新2018-07-02 ActiveMQ安全指南 ,现 ...

相关文章

更多

最新问答

更多
  • 如何保护Solr只允许SELECT请求给用户并禁止其他任何东西?(How to secure Solr to allow SELECT request to only users and disallow anything else?)
  • XPath表达式无效/错误TFHpple SWIFT 1.2(XPath Expression not working/incorrect TFHpple SWIFT 1.2)
  • css3 3D变换不能平滑地制作动画(css3 3D transform doesn't animate smoothly)
  • 运行时错误'91'和Outlook.Application = <对象变量或没有设置块变量>?(Run-time error '91' & Outlook.Application = Object variable or With block variable not set?)
  • 慢的webservice问题(Slow webservice problem)
  • textview的不正确对齐方式(Improper alignment of a textview)
  • 在第一步“Hello World”中出现Java错误(Cannot run “Hello World” program in Eclipse)
  • 为什么十六进制地址是14个字符?(why the hex address is 14 character?)
  • 如何在Python中的不同类中使用变量?(How to use variable in different classes in Python?)
  • asp:GridView HYPERLINKFIELD - datanavigateurlformatstring中的asp代码(asp:GridView HYPERLINKFIELD - asp code inside datanavigateurlformatstring)
  • 关于adaboost算法(About adaboost algorithm)
  • 在Matlab上内置图像(Built in Images on Matlab)
  • java swing:输入键事件时焦点丢失(java swing: Focus lost on enter key event)
  • C#中的通用约束,T是相同的TSomethingElse,对吧?(Generic constraints in C#, T is the same TSomethingElse, right?)
  • 从mybatis中的光标获取数据(Fetching data from cursor in mybatis)
  • 在运行时从XML构建对象的最佳方法(Best way for building objects out of XMLs at runtime)
  • 在整个窗口中拉伸sf :: Sprite(Stretch sf::Sprite across entire window)
  • Selenium Node API Web驱动程序等待超时处理程序(Selenium Node API web driver wait timeout handler)
  • 函数使用并且是map的一部分(循环依赖?)(Function uses and is part of map (circular dependency?))
  • 是否可以在C ++ 14中使用可选模板参数创建类型元组?(Is possible to make a tuple of types with optional template parameters in C++14?)
  • PHP从窗帘后面打印/ f(PHP prints /f from behind the curtains)
  • JFrame的contentPane的LayoutManager(LayoutManager of JFrame's contentPane)
  • 用于Instagram Feed的图像滚动(Image Roll Overs for Instagram Feed)
  • 如何显示拉伸字体(双倍宽度/高度)?(How to display stretched font (double width/height)?)
  • 文件操作API在fileapi.h和stdio.h中的WP8差异?(WP8 differences between file manipulation APIs in fileapi.h and stdio.h?)
  • 保存失败后Rails没有回滚事务()(Rails not rolling back transaction after failed save())
  • jqgrid中的分页问题与数组数据(Pagination problem in jqgrid with array data)
  • 重定向时,通过其他页面上的URL调用javascript函数(Call javascript function through url on otherpage while Redirecting)
  • 如何使用InvokeCommandAction调用我的方法并传入参数?(How do I go about using InvokeCommandAction to call a method of mine and pass in parameters?)
  • Jquerymobile按钮仅显示页面的第一个外观(Jquerymobile buttons are shown only first apperance of the page)