站群cms源码,seo外包网站,检察院网站建设,天津实用网站建设JGroups是Bela Ban的用于可靠消息交换的软件#xff0c;该软件高度可配置#xff0c;可以使用TCP或UDP作为传输协议。 基本上#xff0c;您在多个客户端上运行JGroup#xff0c;它们构成一个集群#xff0c;它们可以在集群内发送和接收消息。 JGroups由JBoss Infinispan内… JGroups是Bela Ban的用于可靠消息交换的软件该软件高度可配置可以使用TCP或UDP作为传输协议。 基本上您在多个客户端上运行JGroup它们构成一个集群它们可以在集群内发送和接收消息。 JGroups由JBoss Infinispan内部使用。 但是与JGroups不同Infinispan添加了分布式缓存语义复制/分布式模式条目无效事务行为Map访问API等。它甚至允许您将集群用作计算网格。 依次使用Infinispan提供JBoss AS 7集群功能。 因此这意味着底层JGroups子系统可以并且使用标准JBoss AS 7 Standalone * .xml文件进行配置。 您可以从Java EE组件例如EJB访问Infinispan缓存而不会出现此处所述的任何问题。 但是在某些情况下您只想使用基础JGroups消息传递而不是Infinispan为您提供的所有缓存语义。 这是事情变得越来越复杂的地方。 您始终可以直接使用JGroups并将其配置存储为应用程序本地资源。 是否违反或违反Java EE规范可能会引起争议Java EE规范规定应用程序不应管理低级连接生成线程打开套接字等。应用服务器-它还使我们可以使用一个配置文件而不是将其分布在多个位置。 因此问题是– 如何从我们的EJB应用程序访问JGroups子系统 整个解决方案涉及几个步骤下面将对其进行描述。 如果要检查整个工作项目 请查看我的JGroups AS7 Github项目 。 1.编写自定义JBoss AS 7服务激活器 该激活器 JGroupsChannelServiceActivator.java 将做两件事 使用JBoss协议配置创建实际的JGroups通道 将新创建的JGroups通道绑定到JNDI。 第一部分在JGroupsChannelServiceActivator#createChannel(-) 。 我不知道ServiceActivator或JBoss AS 7模块的其他内部组件但从中您可以看到 InjectedValueChannelFactory channelFactory new InjectedValue(); ServiceName serviceName ChannelFactoryService.getServiceName(STACK_NAME); ChannelService channelService new ChannelService(CHANNEL_NAME, channelFactory);target.addService(channelServiceName, channelService).addDependency(serviceName, ChannelFactory.class, channelFactory).install(); 似乎它会创建一个新服务 ChannelService 并让JBoss MSC在安装过程中自动注入其依赖的ChannelFactory 。 ChannelFactory将使用UDP协议栈。 第二部分在JGroupsChannelServiceActivator#bindChannelToJNDI(-)完成 JGroupsChannelServiceActivator#bindChannelToJNDI(-)新创建的Channel实例绑定到用户定义位置下的JNDI。 在我们的例子中是java:jboss/channel/myChannel 。 2.注册激活器 现在我们需要告诉JBoss AS 7调用我们的自定义激活器。 使用标准化的JDK ServiceLoader API完成 。 简而言之这意味着我们需要提供一个带有我们激活器类完全限定名称的META-INF/services/org.jboss.msc.service.ServiceActivator文件。 看一下这个例子 。 3.将必需的模块添加到我们的应用程序 好的所以我们有一个应该做魔术的活化剂。 如果我们尝试这样部署它我们将获得一堆ClassNotFoundException 。 这是因为JBoss模块。 我们的应用程序未包含所有这些JBoss工件例如JGroupsServiceActivator API和与JNDI相关的类。 我们不想用这些库弄乱我们的应用程序–我们只想定义JBoss AS 7本身提供的模块依赖性。 我们在META-INF/jboss-deployment-structure.xml 。 请注意我们可以在MANIFEST.MF Dependencies部分中执行此操作但是Intellij IDEA似乎无法与Maven生成的MANIFEST.MF一起使用 ?xml version1.0 encodingUTF-8? jboss-deployment-structuredeploymentdependenciesmodule nameorg.jgroups/module nameorg.jboss.as.naming/module nameorg.jboss.as.clustering.jgroups//dependencies/deployment /jboss-deployment-structure 访问JChannelChannelService等需要JGroups模块。JNDI绑定代码需要命名模块。 4.使用JGroups Channel开发EJB JGroupsSampleDataProducer是一个Singleton EJB它显示了如何访问JGroups通道。 由于具有JNDI绑定因此相当简单。 我们可以使用 Resource(lookup java:jboss/channel/myChannel) private JChannel channel; 在那里。 该EJB注册一个计时器该计时器每2秒被调用一次并发送一些随机的String消息。 注意我们不必显式启动JChannel 。 我们只是注入并直接使用它。 看一下步骤1中在我们的激活器中使用的ChannelService 。它的启动方法如下 Override protected void start() throws Exception {(...)if (this.channel.getProtocolStack().findProtocol(STATE_TRANSFER.class, STATE.class, STATE_SOCK.class) ! null) {this.channel.connect(this.id, null, STATE_TRANSFER_TIMEOUT);} else {this.channel.connect(this.id);} 因此 该服务将自动连接到我们的频道 。 除了使用ChannelService我们还可以开发自己的服务该服务将负责启动和停止我们的频道或者甚至可以将此责任移交给频道的实际用户。 5.部署EJB-JAR 现在我们准备将应用程序部署到JBoss AS 7服务器。 这里最重要的部分是确保我们的服务器将以适当的配置运行这意味着已定义了JGroups协议栈。 使用subsystem xmlnsurn:jboss:domain:jgroups:1.1 。 我正在使用JBoss AS 7.1.1和standalone-full-ha.xml配置。 **注意**因为Intellij IDEA不允许您像Eclipse一样轻松地更改JBoss AS的配置文件所以我们需要使用VM选项来指定它 -Djboss.server.default.configstandalone-full-ha.xml 。 我们还需要确保JGroups将使用IPv4 有时会选择IPv6这可能会导致某些奇怪而又难以解决的问题。为此请在服务器配置中添加-Djava.net.preferIPv4Stacktrue选项。 6.运行客户端应用程序 您可以在此处找到一个相当简单的客户端代码。 它只是使用指定的配置文件连接到JGroups集群。 请注意对于服务器和客户端应将多播端口号和地址设置为相同的值。 另外请记住在运行客户端时添加-Djava.net.preferIPv4Stacktrue VM选项。 希望本教程对您有所帮助并且可以节省一些配置时间。 十分感谢贝拉班了很多重要的建议和保罗·费拉罗指着我初步认识论坛主题像这样或这样就类似的问题之一。 参考在Piotr Nowicki主页博客上我们的JCG合作伙伴 Piotr Nowicki 直接从JBoss AS 7组件直接使用JGroups 。 翻译自: https://www.javacodegeeks.com/2013/03/using-jgroups-directly-from-jboss-as-7-component.html