服务端通知客户端端用的ActiveMQ,能连接JBoss发布的JMS消息吗

一、 概述与介绍

那么我告诉你佷不幸,你的端口被占用了接下来你大概想知道是哪个程序占用了你的端口,并kill掉该进程或服务或者你要尝试修改ActiveMQ的默认端口61616(ActiveMQ使用嘚默认端口是61616),在大多数情况下占用61616端口的是Internet Connection Sharing (ICS) 这个Windows服务,你只需停止它就可以启动ActiveMQ了

4、 启动成功就可以访问管理员界面:,默认用戶名和密码admin/admin如果你想修改用户名和密码的话,在conf/jetty-/IBM_hoojo

 
 
 
 
 
 
 

这里的整合就比较简单了如果你是web工程,那你在需要用jms的时候只需用注入jmsTemplate即可。


}

OpenShift是“红帽开发的开放式混合云应鼡程序平台” 它具有不同的风格,对于大多数您想做的事情最有趣的部分是公共云应用程序开发和托管平台“ ”。 您可以轻松地尝试┅下因为在云中使用OpenShift Online是免费的,而且很容易 它所需要的只是一个。 该免费产品允许最多三个基本的小型设备并可以托管来自多种不哃语言和框架的三个应用程序。 如果您需要更多可以将您的计划升级到付费版本。 有关更多详细信息请访问。

Java消息服务是跨系统通信嘚有效方法即使在非Java应用程序之间也是如此。 通过基于开放源代码技术和严格的标准RedHat OpenShift使开发人员可以轻松地将其JMS应用程序移动到云中,或编写利用JMS消息和加密的Internet连接的新系统

这篇文章将介绍使用两个主要应用程序的方法:用于托管Web应用程序的和用于异步消息传递的 。 這两个应用程序都可以在OpenShift的免费层中运行

通过将A-MQ部署到OpenShift云,您的设备将收到几个可公开访问的端口 然后,服务端通知客户端端系统可鉯使用这些远程端口连接到您的A-MQ服务 端点需要加密,因此不会在Internet上以纯文本形式发送JMS消息

创建A-MQ装备的第一步是克隆现有的JBoss Fuse A-MQ墨盒。 对于那些对墨盒管理感兴趣的人可以查看。 (注意:如果您正在寻找带有ActiveMQ的上游墨盒 )

  • 齿轮名–管理控制台中齿轮的名称。
  • PORT –创建盒带时提供嘚数字端口号

您的OpenShift实例中提供了标准A-MQ实例的许多配置选项。 为此的配置文件是:

有一些警告 即,您可以更改<transportConnector />的协议但不能更改IP或端ロ。 这些端口由您的OpenShift Gear控制并且实际上是外部区域唯一允许的端口。

OpenShift被设计为资源共享系统并且空闲资源实际上将进入睡眠状态,直到被访问为止 JMS在OpenShift上造成了一个特殊的问题,即如果JMS处于空闲状态则连接将不起作用,新服务端通知客户端端也将无法连接

为防止这种凊况,请自动执行一个脚本该脚本会定期与JBoss Fuse Web控制台进行交互,或者始终保持至少一个服务端通知客户端端与您的A-MQ连接

}

JMS是用于访问企业消息系统的开发商中立的API企业消息系统可以协助应用软件通过网络进行消息交互。

JMS的编程过程很简单概括为:应用程序A发送一条消息到消息服务器的某个目得地(Destination),然后消息服务器把消息转发给应用程序B因为应用程序A和应用程序B没有直接的代码关连,所以两者实现了解偶

   它是专门用於异步处理java消息的组件.具有处理大量并发消息的能力.

在某些情况下,由于SessionBean方法的执行时间比较长这就需要异步地调用该方法,否则服务端通知客户端端就需要等待比较长的时间要实现异步调用, 就需要使用消息驱动Bean

消息驱动Bean的基本原理是服务端通知客户端端向消息服務器发送一条消息后,消息服务器会将该消息保存在消息队列中在这时消 息服务器中的某个消费者(读取并处理消息的对象)会读取该消息,并进行处理发送消息的服务端通知客户端端被称为消息生产者。

消息传递系统的中心就是消息一条 Message 由三个部分组成: 

消息有下媔几种类型,他们都是派生自 Message 接口

StreamMessage:一种主体中包含 Java 基元值流的消息。其填充和读取均按顺序进行

MapMessage:一种主体中包含一组名-值对的消息。没有定义条目顺序

TextMessage:一种主体中包含 Java 字符串的消息(例如,XML 消息)

BytesMessage:一种主体中包含连续字节流的消息

这两种消息传递模型非常楿似,但有以下区别:

JMS中消息的 同步消费 和 异步消费

同步消费中消息的接收者会一直等待下去,直到有消息到达或者超时

System.in.read();  //这句话是為了人为的阻塞程序不然 还没接收到消息 程序一下子就执行完了,关闭了

异步消费会注册一个监听器,当有消息到达的时候会回调咜的onMessage()方法,没有次数限制

}

我要回帖

更多关于 服务端通知客户端 的文章

更多推荐

版权声明:文章内容来源于网络,版权归原作者所有,如有侵权请点击这里与我们联系,我们将及时删除。

点击添加站长微信