You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2014/12/01 18:44:08 UTC
[10/11] activemq-6 git commit: ACTIVEMQ6-49 Remove the obsolete
chinese doc
ACTIVEMQ6-49 Remove the obsolete chinese doc
Project: http://git-wip-us.apache.org/repos/asf/activemq-6/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-6/commit/d18c42b0
Tree: http://git-wip-us.apache.org/repos/asf/activemq-6/tree/d18c42b0
Diff: http://git-wip-us.apache.org/repos/asf/activemq-6/diff/d18c42b0
Branch: refs/heads/master
Commit: d18c42b0774eacf17cbbb38b2e1b59c98a7716bd
Parents: 5996d69
Author: Howard Gao <hg...@redhat.com>
Authored: Mon Dec 1 11:25:19 2014 +0800
Committer: Howard Gao <hg...@redhat.com>
Committed: Mon Dec 1 11:25:19 2014 +0800
----------------------------------------------------------------------
docs/user-manual/zh/appserver-integration.xml | 1001 --------------
docs/user-manual/zh/architecture.xml | 95 --
docs/user-manual/zh/client-classpath.xml | 47 -
docs/user-manual/zh/client-reconnection.xml | 116 --
docs/user-manual/zh/clusters.xml | 550 --------
docs/user-manual/zh/configuration-index.xml | 1284 ------------------
docs/user-manual/zh/configuring-transports.xml | 376 -----
docs/user-manual/zh/connection-ttl.xml | 139 --
docs/user-manual/zh/core-bridges.xml | 179 ---
.../zh/diagrams/architecture-diagrams.odg | Bin 10587 -> 0 bytes
.../zh/diagrams/ha-replicated-store.odg | Bin 11620 -> 0 bytes
.../user-manual/zh/diagrams/ha-shared-store.odg | Bin 10650 -> 0 bytes
docs/user-manual/zh/diverts.xml | 86 --
docs/user-manual/zh/duplicate-detection.xml | 120 --
docs/user-manual/zh/embedding-hornetq.xml | 178 ---
docs/user-manual/zh/examples.xml | 427 ------
docs/user-manual/zh/filter-expressions.xml | 71 -
docs/user-manual/zh/flow-control.xml | 243 ----
docs/user-manual/zh/ha.xml | 283 ----
docs/user-manual/zh/images/architecture1.jpg | Bin 19948 -> 0 bytes
docs/user-manual/zh/images/architecture2.jpg | Bin 18718 -> 0 bytes
docs/user-manual/zh/images/architecture3.jpg | Bin 12274 -> 0 bytes
docs/user-manual/zh/images/console1.png | Bin 81814 -> 0 bytes
.../zh/images/ha-replicated-store.png | Bin 21496 -> 0 bytes
docs/user-manual/zh/images/ha-shared-store.png | Bin 14147 -> 0 bytes
.../zh/images/hornetQ-banner_final.png | Bin 109633 -> 0 bytes
.../zh/images/hornetQ_logo_600px.png | Bin 23866 -> 0 bytes
docs/user-manual/zh/intercepting-operations.xml | 71 -
docs/user-manual/zh/interoperability.xml | 142 --
docs/user-manual/zh/jms-bridge.xml | 382 ------
docs/user-manual/zh/jms-core-mapping.xml | 42 -
docs/user-manual/zh/large-messages.xml | 234 ----
docs/user-manual/zh/last-value-queues.xml | 66 -
docs/user-manual/zh/libaio.xml | 114 --
docs/user-manual/zh/logging.xml | 46 -
docs/user-manual/zh/management.xml | 805 -----------
docs/user-manual/zh/master.xml | 128 --
docs/user-manual/zh/message-expiry.xml | 81 --
docs/user-manual/zh/message-grouping.xml | 149 --
docs/user-manual/zh/messaging-concepts.xml | 164 ---
docs/user-manual/zh/notice.xml | 27 -
docs/user-manual/zh/paging.xml | 198 ---
docs/user-manual/zh/perf-tuning.xml | 233 ----
docs/user-manual/zh/persistence.xml | 263 ----
docs/user-manual/zh/pre-acknowledge.xml | 72 -
docs/user-manual/zh/preface.xml | 68 -
docs/user-manual/zh/project-info.xml | 89 --
docs/user-manual/zh/queue-attributes.xml | 120 --
docs/user-manual/zh/scheduled-messages.xml | 47 -
docs/user-manual/zh/security.xml | 235 ----
docs/user-manual/zh/send-guarantees.xml | 102 --
docs/user-manual/zh/thread-pooling.xml | 108 --
docs/user-manual/zh/transaction-config.xml | 29 -
docs/user-manual/zh/undelivered-messages.xml | 118 --
docs/user-manual/zh/using-core.xml | 163 ---
docs/user-manual/zh/using-jms.xml | 273 ----
docs/user-manual/zh/using-server.xml | 312 -----
docs/user-manual/zh/wildcard-routing.xml | 37 -
docs/user-manual/zh/wildcard-syntax.xml | 37 -
59 files changed, 10150 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-6/blob/d18c42b0/docs/user-manual/zh/appserver-integration.xml
----------------------------------------------------------------------
diff --git a/docs/user-manual/zh/appserver-integration.xml b/docs/user-manual/zh/appserver-integration.xml
deleted file mode 100644
index 9f975e4..0000000
--- a/docs/user-manual/zh/appserver-integration.xml
+++ /dev/null
@@ -1,1001 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!-- ============================================================================= -->
-<!-- Copyright © 2009 Red Hat, Inc. and others. -->
-<!-- -->
-<!-- The text of and illustrations in this document are licensed by Red Hat under -->
-<!-- a Creative Commons Attribution–Share Alike 3.0 Unported license ("CC-BY-SA"). -->
-<!-- -->
-<!-- An explanation of CC-BY-SA is available at -->
-<!-- -->
-<!-- http://creativecommons.org/licenses/by-sa/3.0/. -->
-<!-- -->
-<!-- In accordance with CC-BY-SA, if you distribute this document or an adaptation -->
-<!-- of it, you must provide the URL for the original version. -->
-<!-- -->
-<!-- Red Hat, as the licensor of this document, waives the right to enforce, -->
-<!-- and agrees not to assert, Section 4d of CC-BY-SA to the fullest extent -->
-<!-- permitted by applicable law. -->
-<!-- ============================================================================= -->
-<chapter id="appserver-integration">
- <title>Java EE和应用服务器的集成</title>
- <para>ActiveMQ可以容易地安装到JBoss 4应用服务器及其以上版本。有关安装的详细说明请参阅快速指南。</para>
- <para>ActiveMQ提供了一个JCA适配器，使得它还可以与其它JEE兼容的应用服务器集成。请参阅其它应用服务器的
- 有关JCA适配器集成的说明来操作。</para>
- <para>JCA适配器的作用是控制消息流入到消息Bean（MDB），并控制消息从各种JEE模块中发出（如EJB和Servlet）。</para>
- <para>本章讲述这些JEE模块配置ActiveMQ的基本信息。</para>
- <section>
- <title>配置消息Bean</title>
- <para>使用ActiveMQ向MDB传递消息，需要在文件<literal>ra.xml</literal>中配置JCA适配器。该文件在
- <literal>jms-ra.rar</literal>文件中。默认配置下ActiveMQ服务使用InVm连接器接收消息。在本章
- 后面列出了可配置的选项。</para>
- <para>所有MDB都需要有目标类型和目标的相关配置。下面就是一个使用annotation配置MDB的例子：</para>
- <programlisting>@MessageDriven(name = "MDBExample",
- activationConfig =
- {
- @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
- @ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/testQueue")
- })
-@ResourceAdapter("activemq-ra.rar")
-public class MDBExample implements MessageListener
-{
- public void onMessage(Message message)...
-}</programlisting>
- <para>上例中配置了MDB从一个队列中接收消息，它的JNDI绑定名为<literal>queue/testQueue</literal>。
- 这个队列必须事先在ActiveMQ服务器配置文件中配置并部署好的。</para>
- <para><literal>ResourceAdapter</literal> annotation用来指出使用哪个适配器。要使用它必须要引入
- <literal>org.jboss.ejb3.annotation.ResourceAdapter</literal> （JBoss AS 5.x或以上）。
- 这个类在
- <literal>jboss-ejb3-ext-api.jar</literal>文件中。该文件可以在JBoss的repository中找到。
- 另外一个方法是使用部署描述文件（deployment descriptor），即在文件<literal
- >jboss.xml</literal>中加入类似以下的内容：
-<programlisting><message-driven>
- <ejb-name>ExampleMDB</ejb-name>
- <resource-adapter-name>activemq-ra.rar</resource-adapter-name>
-</message-driven>
-</programlisting>你还可以将activemq-ra.rar改名为jms-ra.rar而不需要任何annotation或额外的部署描述信息。但是你需要
- 编辑<literal>jms-ds.xml</literal>文件，将其中的<literal>rar-name</literal>项改成相应的值。</para>
- <note>
- <para>ActiveMQ是JBoss AS 6默认的JMS提供者。从这个版本开始ActiveMQ的资源适配器名字是
- <literal>jms-ra.rar</literal>，并且你不需要在MDB的annotation中指定它。</para>
- </note>
- <para>ActiveMQ发布包中的所有例子都使用annotation方法。</para>
- <section>
- <title>使用容器管理事务（CMT）</title>
- <para>当MDB使用容器管理事务时，消息的传递被包含在一个JTA事务中。事务的提交与回滚是由容器来控制的。如果事务
- 被回滚，消息传递会进行相应的处理（默认是重新传递消息，如果重新传递次数超过10次，消息就被发往DLQ）。使用
- annotation配置如下：</para>
- <programlisting>@MessageDriven(name = "MDB_CMP_TxRequiredExample",
- activationConfig =
- {
- @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
- @ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/testQueue")
- })
-@TransactionManagement(value= TransactionManagementType.CONTAINER)
-@TransactionAttribute(value= TransactionAttributeType.REQUIRED)
-@ResourceAdapter("activemq-ra.rar")
-public class MDB_CMP_TxRequiredExample implements MessageListener
-{
- public void onMessage(Message message)...
-}</programlisting>
- <para><literal>TransactionManagement</literal> 表示这个MDB使用容器管理持久性。
- <literal>TransactionAttribute</literal> 表示这个MDB要求JTA事务。注意这个annotation的
- 另外唯一的合法值是<literal>TransactionAttributeType.NOT_SUPPORTED</literal>，它表示
- MDB不需要JTA事务支持。</para>
- <para>如果要回滚事务，可以调用<literal>MessageDrivenContext</literal>的
- <literal>setRollbackOnly</literal>方法。如下面的代码所示：</para>
- <programlisting> @Resource
- MessageDrivenContextContext ctx;
-
- public void onMessage(Message message)
- {
- try
- {
- //something here fails
- }
- catch (Exception e)
- {
- ctx.setRollbackOnly();
- }
- }</programlisting>
- <para>如果你不需要使用XA事务，你可以用一相本地的事务来代替（比如你只有一个JMS资源）。
- 如下所示：</para>
- <programlisting>@MessageDriven(name = "MDB_CMP_TxLocalExample",
- activationConfig =
- {
- @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
- @ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/testQueue"),
- @ActivationConfigProperty(propertyName = "useLocalTx", propertyValue = "true")
- })
-@TransactionManagement(value = TransactionManagementType.CONTAINER)
-@TransactionAttribute(value = TransactionAttributeType.NOT_SUPPORTED)
-@ResourceAdapter("activemq-ra.rar")
-public class MDB_CMP_TxLocalExample implements MessageListener
-{
- public void onMessage(Message message)...
-}</programlisting>
- </section>
- <section>
- <title>使用Bean管理事务（BMT）</title>
- <para>消息Bean可以通过配置使用Bean管理的事务（BMT）。在种情况下会创建一个用户事务
- （User Transaction）。如下所示：</para>
- <programlisting>@MessageDriven(name = "MDB_BMPExample",
- activationConfig =
- {
- @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
- @ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/testQueue"),
- @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Dups-ok-acknowledge")
- })
-@TransactionManagement(value= TransactionManagementType.BEAN)
-@ResourceAdapter("activemq-ra.rar")
-public class MDB_BMPExample implements MessageListener
-{
- public void onMessage(Message message)
-}</programlisting>
- <para>使用BMT时，消息的传递在用户事务的范围之外，它的通知模式由<literal>acknowledgeMode</literal>参数决定。
- 该参数有两个合法的值，即<literal>Auto-acknowledge</literal>和<literal
- >Dups-ok-acknowledge</literal>。请注意，由于消息的传递在事务之外，在MDB中如果发生错误消息
- 是不会重新传递的。</para>
- <para>用户可以像如下所示控制事务的生命周期：</para>
- <programlisting> @Resource
- MessageDrivenContext ctx;
-
- public void onMessage(Message message)
- {
- UserTransaction tx;
- try
- {
- TextMessage textMessage = (TextMessage)message;
-
- String text = textMessage.getText();
-
- UserTransaction tx = ctx.getUserTransaction();
-
- tx.begin();
-
- //do some stuff within the transaction
-
- tx.commit();
-
- }
- catch (Exception e)
- {
- tx.rollback();
- }
- }</programlisting>
- </section>
- <section>
- <title>在MDB中使用选择器</title>
- <para>MDB可以配置消息选择器。如下所示：</para>
- <programlisting>@MessageDriven(name = "MDBMessageSelectorExample",
- activationConfig =
- {
- @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
- @ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/testQueue"),
- @ActivationConfigProperty(propertyName = "messageSelector", propertyValue = "color = 'RED'")
- })
-@TransactionManagement(value= TransactionManagementType.CONTAINER)
-@TransactionAttribute(value= TransactionAttributeType.REQUIRED)
-@ResourceAdapter("activemq-ra.rar")
-public class MDBMessageSelectorExample implements MessageListener
-{
- public void onMessage(Message message)....
-}</programlisting>
- </section>
- </section>
- <section>
- <title>在JEE模块内发送消息</title>
- <para>JCA适配器支持发送消息。连接工厂的默认配置在<literal>jms-ds.xml</literal>文件中，对应的JNDI名字是
- <literal>java:/JmsXA</literal>。在JEE中使用它发送消息将作为JTA事务的一部分来对待。</para>
- <para>如果消息发送失败，整个事务将回滚，消息会被重新发送。下面是一个MDB发送消息的例子：</para>
- <programlisting>@MessageDriven(name = "MDBMessageSendTxExample",
- activationConfig =
- {
- @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
- @ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/testQueue")
- })
-@TransactionManagement(value= TransactionManagementType.CONTAINER)
-@TransactionAttribute(value= TransactionAttributeType.REQUIRED)
-@ResourceAdapter("activemq-ra.rar")
-public class MDBMessageSendTxExample implements MessageListener
-{
- @Resource(mappedName = "java:/JmsXA")
- ConnectionFactory connectionFactory;
-
- @Resource(mappedName = "queue/replyQueue")
- Queue replyQueue;
-
- public void onMessage(Message message)
- {
- Connection conn = null;
- try
- {
- //Step 9. We know the client is sending a text message so we cast
- TextMessage textMessage = (TextMessage)message;
-
- //Step 10. get the text from the message.
- String text = textMessage.getText();
-
- System.out.println("message " + text);
-
- conn = connectionFactory.createConnection();
-
- Session sess = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
-
- MessageProducer producer = sess.createProducer(replyQueue);
-
- producer.send(sess.createTextMessage("this is a reply"));
-
- }
- catch (Exception e)
- {
- e.printStackTrace();
- }
- finally
- {
- if(conn != null)
- {
- try
- {
- conn.close();
- }
- catch (JMSException e)
- {
- }
- }
- }
- }
- }</programlisting>
- <para>在JBoss应用服务器的EJB（包括会话Bean, 实体Bean和消息Bean）、Servlet（包括jsp）我定制的MBean中
- 都可以使用JMS的JCA适配器来发送消息。</para>
- </section>
- <section>
- <title>MDB与接收池的大小</title>
- <para>包括JBoss在内的绝大多数应用服务器允许用户定义一个池中的MDB数量。在JBoss中这个参数名是<literal>MaxPoolSize</literal>，它在文件
- ejb3-interceptors-aop.xml中配置。这个参数不影响实际创建的会话／接收者的数量。资源适配器不知道MDB的具体实现。所以即使你设置MDB池在大小
- 为1，仍然会有15个会话／接收者被创建（默认值）。如果你想改变会话／接收者创建的数量，你可以通过设置资源适配器的参数
- <literal>maxSession</literal>实现。也可以通过设置MDB的激活配置参数来完成：</para>
- <programlisting>@MessageDriven(name = "MDBMessageSendTxExample",
- activationConfig =
- {
- @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
- @ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/testQueue"),
- @ActivationConfigProperty(propertyName = "maxSession", propertyValue = "1")
- })
-@TransactionManagement(value= TransactionManagementType.CONTAINER)
-@TransactionAttribute(value= TransactionAttributeType.REQUIRED)
-@ResourceAdapter("activemq-ra.rar")
-public class MyMDB implements MessageListener
-{ ....}
- </programlisting>
- </section>
- <section>
- <title>配置JCA适配器</title>
- <para>通过JCA适配器可以将ActiveMQ集成到JEE兼容的模块中，如MDB和EJB。它的配置决定了这些模块如何接收和发送消息。</para>
- <para>ActiveMQ的JCA适配器是通过<literal>jms-ra.rar</literal>部署的。它的配置文件中其中的
- <literal>META-INF/ra.xml</literal>。</para>
- <para>下面是它的具体配置内容：</para>
- <programlisting><resourceadapter>
- <resourceadapter-class>org.apache.activemq.ra.ActiveMQResourceAdapter</resourceadapter-class>
- <config-property>
- <description>The transport type</description>
- <config-property-name>ConnectorClassName</config-property-name>
- <config-property-type>java.lang.String</config-property-type>
- <config-property-value>org.apache.activemq.core.remoting.impl.invm.InVMConnectorF
- actory</config-property-value>
- </config-property>
- <config-property>
- <description>The transport configuration. These values must be in the form of key=val;key=val;</description>
- <config-property-name>ConnectionParameters</config-property-name>
- <config-property-type>java.lang.String</config-property-type>
- <config-property-value>server-id=0</config-property-value>
- </config-property>
-
- <outbound-resourceadapter>
- <connection-definition>
- <managedconnectionfactory-class>org.apache.activemq.ra.ActiveMQRAManagedConnection
- Factory</managedconnectionfactory-class>
-
- <config-property>
- <description>The default session type</description>
- <config-property-name>SessionDefaultType</config-property-name>
- <config-property-type>java.lang.String</config-property-type>
- <config-property-value>javax.jms.Queue</config-property-value>
- </config-property>
- <config-property>
- <description>Try to obtain a lock within specified number of seconds; less
- than or equal to 0 disable this functionality</description>
- <config-property-name>UseTryLock</config-property-name>
- <config-property-type>java.lang.Integer</config-property-type>
- <config-property-value>0</config-property-value>
- </config-property>
-
- <connectionfactory-interface>org.apache.activemq.ra.ActiveMQRAConnectionFactory
- </connectionfactory-interface>
- <connectionfactororg.apache.activemq.ra.ActiveMQConnectionFactoryImplonFactoryImpl
- </connectionfactory-impl-class>
- <connection-interface>javax.jms.Session</connection-interface>
- <connection-impl-class>org.apache.activemq.ra.ActiveMQRASession
- </connection-impl-class>
- </connection-definition>
- <transaction-support>XATransaction</transaction-support>
- <authentication-mechanism>
- <authentication-mechanism-type>BasicPassword
- </authentication-mechanism-type>
- <credential-interface>javax.resource.spi.security.PasswordCredential
- </credential-interface>
- </authentication-mechanism>
- <reauthentication-support>false</reauthentication-support>
- </outbound-resourceadapter>
-
- <inbound-resourceadapter>
- <messageadapter>
- <messagelistener>
- <messagelistener-type>javax.jms.MessageListener</messagelistener-type>
- <activationspec>
- <activationspec-class>org.apache.activemq.ra.inflow.ActiveMQActivationSpec
- </activationspec-class>
- <required-config-property>
- <config-property-name>destination</config-property-name>
- </required-config-property>
- </activationspec>
- </messagelistener>
- </messageadapter>
- </inbound-resourceadapter>
-
- </resourceadapter></programlisting>
- <para>整个配置可以分为三个主要部分</para>
- <orderedlist>
- <listitem>
- <para>适配器的全局参数</para>
- </listitem>
- <listitem>
- <para>适配器外部（outbound）配置。用于在JEE环境中创建JMS资源。</para>
- </listitem>
- <listitem>
- <para>适配器内部（inbound）配置。用于控制MDB的消息接收。 </para>
- </listitem>
- </orderedlist>
- <section>
- <title>适配器的全局参数</title>
- <para>首先看到的第一个参数是<literal>resourceadapter-class</literal>。这是ActiveMQ
- 的适配器类。此参数不可更改。</para>
- <para>在此之后是可配置的参数。前两个配置适配器所使用的传输。其余的用来配置连接工厂。</para>
- <note><para>所有连接工厂的参数在没有定义时使用默认值。参数<literal>reconnectAttempts</literal>
- 的默认值取-1，表示如果连接失败，ActiveMQ会不停地尝试重新连接。这个参数只适用于创建远程
- 连接的情况。如果是InVm连接器，则永远不可能发生连接故障。</para></note>
- <para>下面给出了每个参数的说明：</para>
- <table frame="topbot" border="2">
- <title>全局配置参数</title>
- <tgroup cols="3">
- <colspec colname="c1" colnum="1"/>
- <colspec colname="c2" colnum="2"/>
- <colspec colname="c3" colnum="3"/>
- <thead>
- <row>
- <entry>参数名</entry>
- <entry>参数类型</entry>
- <entry>参数说明</entry>
- </row>
- </thead>
- <tbody>
- <row>
- <entry>ConnectorClassName</entry>
- <entry>String</entry>
- <entry>连接器的类名，参见 <xref
- linkend="configuring-transports"/></entry>
- </row>
- <row>
- <entry>ConnectionParameters</entry>
- <entry>String</entry>
- <entry>传输配置参数。它的值必须是采用
- <literal>key1=val1;key2=val2;</literal>的形式。不同连接器有不同的参数。</entry>
- </row>
- <row>
- <entry>useLocalTx</entry>
- <entry>boolean</entry>
- <entry>设为True，则进行本地事务优化。</entry>
- </row>
- <row>
- <entry>UserName</entry>
- <entry>String</entry>
- <entry>用于创建连接时使用的用户名</entry>
- </row>
- <row>
- <entry>Password</entry>
- <entry>String</entry>
- <entry>用于创建连接时使用的用户密码</entry>
- </row>
- <row>
- <entry>BackupConnectorClassName</entry>
- <entry>String</entry>
- <entry>发生故障是使用的备份传输</entry>
- </row>
- <row>
- <entry>BackupConnectionParameters</entry>
- <entry>String</entry>
- <entry>备份传输的配置参数</entry>
- </row>
- <row>
- <entry><link linkend="configuration.discovery-group.group-address">DiscoveryAddress</link></entry>
- <entry>String</entry>
- <entry>服务器自动检测所使用的发现组（discovery group）地址</entry>
- </row>
- <row>
- <entry><link linkend="configuration.discovery-group.group-port">DiscoveryPort</link></entry>
- <entry>Integer</entry>
- <entry>检测所使用的端口号</entry>
- </row>
- <row>
- <entry><link linkend="configuration.discovery-group.refresh-timeout">DiscoveryRefreshTimeout</link></entry>
- <entry>Long</entry>
- <entry>刷新的时间（timeout）。单位为毫秒</entry>
- </row>
- <row>
- <entry>
- <link linkend="configuration.connection-factory.discovery-initial-wait-timeout">
- DiscoveryInitialWaitTimeout
- </link>
- </entry>
- <entry>Long</entry>
- <entry>检测之前所需等待的时间</entry>
- </row>
- <row>
- <entry>
- <link linkend="configuration.connection-factory.connection-load-balancing-policy-class-name">
- ConnectionLoadBalancingPolicyClassName</link>
- </entry>
- <entry>String</entry>
- <entry>负载均衡策略使用的类</entry>
- </row>
- <row>
- <entry>
- <link linkend="configuration.connection-factory.discovery-initial-wait-timeout">
- DiscoveryInitialWaitTimeout
- </link>
- </entry>
- <entry>Long</entry>
- <entry>向服务器发送ping的周期，单位毫秒</entry>
- </row>
- <row>
- <entry>
- <link linkend="configuration.connection-factory.connection-ttl">ConnectionTTL</link>
- </entry>
- <entry>Long</entry>
- <entry>连接的存活时间（TTL）</entry>
- </row>
- <row>
- <entry>
- <link linkend="configuration.connection-factory.call-timeout">CallTimeout</link>
- </entry>
- <entry>Long</entry>
- <entry>每个数据包的调用超时。单位毫秒</entry>
- </row>
- <row>
- <entry>
- <link linkend="configuration.connection-factory.dups-ok-batch-size">DupsOKBatchSize</link>
- </entry>
- <entry>Integer</entry>
- <entry>Dups OK的情况下消息批量的大小。</entry>
- </row>
- <row>
- <entry>
- <link linkend="configuration.connection-factory.transaction-batch-size">TransactionBatchSize</link>
- </entry>
- <entry>Integer</entry>
- <entry>在事务中发送消息的批量大小</entry>
- </row>
- <row>
- <entry>
- <link linkend="configuration.connection-factory.consumer-window-size">ConsumerWindowSize</link>
- </entry>
- <entry>Integer</entry>
- <entry>接收者内部缓存的窗口大小</entry>
- </row>
- </tbody>
- </tgroup>
- </table>
- <para>接上页..</para>
- <informaltable frame="topbot">
- <tgroup cols="3">
- <colspec colname="c1" colnum="1"/>
- <colspec colname="c2" colnum="2"/>
- <colspec colname="c3" colnum="3"/>
- <tbody>
- <row>
- <entry>
- <link linkend="configuration.connection-factory.consumer-max-rate">ConsumerMaxRate</link>
- </entry>
- <entry>Integer</entry>
- <entry>接收者接收消息的最大速度</entry>
- </row>
- <row>
- <entry>
- <link linkend="configuration.connection-factory.confirmation-window-size">ConfirmationWindowSize</link>
- </entry>
- <entry>Integer</entry>
- <entry>用于确认的窗口大小</entry>
- </row>
- <row>
- <entry>
- <link linkend="configuration.connection-factory.producer-max-rate">ProducerMaxRate</link>
- </entry>
- <entry>Integer</entry>
- <entry>发送者发送消息的最大速度</entry>
- </row>
- <row>
- <entry>
- <link linkend="configuration.connection-factory.min-large-message-size">MinLargeMessageSize</link>
- </entry>
- <entry>Integer</entry>
- <entry>大消息的最小数值，单位字节。</entry>
- </row>
- <row>
- <entry>
- <link linkend="configuration.connection-factory.block-on-acknowledge">BlockOnAcknowledge</link>
- </entry>
- <entry>Boolean</entry>
- <entry>如果为true，表示以阻塞方法发送消息通知。</entry>
- </row>
- <row>
- <entry>
- <link linkend="configuration.connection-factory.block-on-non-durable-send">BlockOnNonDurableSend</link>
- </entry>
- <entry>Boolean</entry>
- <entry>如果为true，表示以阻塞方式发送非持久消息</entry>
- </row>
- <row>
- <entry>
- <link linkend="configuration.connection-factory.block-on-durable-send">BlockOnDurableSend</link>
- </entry>
- <entry>Boolean</entry>
- <entry>如果为true，表示以阻塞方式发送持久消息</entry>
- </row>
- <row>
- <entry>
- <link linkend="configuration.connection-factory.auto-group">AutoGroup</link>
- </entry>
- <entry>Boolean</entry>
- <entry>如果为true，表示自动消息分组</entry>
- </row>
- <row>
- <entry>
- <link linkend="configuration.connection-factory.pre-acknowledge">PreAcknowledge</link>
- </entry>
- <entry>Boolean</entry>
- <entry>决定是否进行消息的预先通知（pre-acknowledge）。</entry>
- </row>
- <row>
- <entry>
- <link linkend="configuration.connection-factory.reconnect-attempts">ReconnectAttempts</link>
- </entry>
- <entry>Integer</entry>
- <entry>连接重试的次数，默认为 -1</entry>
- </row>
- <row>
- <entry>
- <link linkend="configuration.connection-factory.retry-interval">RetryInterval</link>
- </entry>
- <entry>Long</entry>
- <entry>每次连接重试前等待的时间，单位毫秒。</entry>
- </row>
- <row>
- <entry>
- <link linkend="configuration.connection-factory.retry-interval-multiplier">RetryIntervalMultiplier</link>
- </entry>
- <entry>Double</entry>
- <entry>用于计算重试间隔</entry>
- </row>
- <row>
- <entry>
- <link linkend="configuration.connection-factory.failover-on-server-shutdown">FailoverOnServerShutdown</link>
- </entry>
- <entry>Boolean</entry>
- <entry>如果设为true表示尝试连接其它的服务器</entry>
- </row>
- <row>
- <entry>
- <link linkend="configuration.connection-factory.client-id">ClientID</link>
- </entry>
- <entry>String</entry>
- <entry>连接的客户端ID</entry>
- </row>
- <row>
- <entry>
- <link linkend="configuration.connection-factory.client-failure-check-period">ClientFailureCheckPeriod</link>
- </entry>
- <entry>Long</entry>
- <entry>客户端如果在这个时间内没有收到服务器数据包，将认为连接出现故障。</entry>
- </row>
- <row>
- <entry>
- <link linkend="configuration.connection-factory.use-global-pools">UseGlobalPools</link>
- </entry>
- <entry>Boolean</entry>
- <entry>是否使用全局线程池</entry>
- </row>
- <row>
- <entry>
- <link linkend="configuration.connection-factory.scheduled-thread-pool-max-size">ScheduledThreadPoolMaxSize</link>
- </entry>
- <entry>Integer</entry>
- <entry><emphasis>可计划线程池</emphasis>的最大线程数</entry>
- </row>
- <row>
- <entry>
- <link linkend="configuration.connection-factory.thread-pool-max-size">ThreadPoolMaxSize</link>
- </entry>
- <entry>Integer</entry>
- <entry>线程池的大小</entry>
- </row>
- <row>
- <entry>SetupAttempts</entry>
- <entry>Integer</entry>
- <entry>尝试建立JMS连接的次数（默认值是10。-1表示无限次进行尝试）。有时MDB在部署时相关的JMS资源还没有准备好，这时通过多次的
- 尝试直到JMS资源连接上为止。只适用于内部（Inbound）连接的情况。</entry>
- </row>
- <row>
- <entry>SetupInterval</entry>
- <entry>Long</entry>
- <entry>每两次相邻尝试之间的时间间隔，以毫秒为单位（默认值为2000毫秒）。只适用于内部（Inbound）连接的情况。</entry>
- </row>
- </tbody>
- </tgroup>
- </informaltable>
- </section>
- <section>
- <title>适配器外部（outbound）配置</title>
- <para>外部配置参数应该保持不变。这是因为它所定义的连接工厂要被Java EE的模块所使用。这些连接工厂
- 可以定义在名字样式为<literal>*-ds.xml</literal>的配置文件中。在JBoss的部署目录
- <literal>activemq.sar</literal>下有一个默认的配置文件<literal>jms-ds.xml</literal>。
- 在这个文件中的连接工厂的配置从主要的配置文件<literal>ra.xml</literal>中继承，
- 但是可以在这里重新定义。下面的例子中给出了重新定义的方法。</para>
- <note>
- <para>请注意这里的配置只适用于在JBoss应用服务器中安装的ActiveMQ。如果要在其它JEE应用服务器中
- 使用并配置ActiveMQ，请参照相应的应用服务器手册。</para>
- </note>
- <programlisting><tx-connection-factory>
- <jndi-name>RemoteJmsXA</jndi-name>
- <xa-transaction/>
- <rar-name>jms-ra.rar</rar-name>
- <connection-definition>org.apache.activemq.ra.ActiveMQRAConnectionFactory
-</connection-definition>
- <config-property name="SessionDefaultType" type="String">javax.jms.Topic
- </config-property>
- <config-property name="ConnectorClassName" type="String">
- org.apache.activemq.core.remoting.impl.netty.NettyConnectorFactory
- </config-property>
- <config-property name="ConnectionParameters" type="String">
- port=5445</config-property>
- <max-pool-size>20</max-pool-size>
-</tx-connection-factory></programlisting>
- <para>上面的例子中的连接工厂绑定到JNDI名字<literal>RemoteJmsXA</literal>。EJB和MDB可以用
- 下面的方法来得到它：</para>
- <programlisting>@Resource(mappedName="java:RemoteJmsXA")
-private ConnectionFactory connectionFactory;</programlisting>
- <para><literal>config-property</literal>覆盖了<literal>ra.xml</literal>文件中的配置。
- 以此类推，其它有关连接工厂的参数也可以在此覆盖。</para>
- <para>除了全局的配置参数外，外部的配置还定义了其它一些参数。</para>
-
- <table frame="topbot" border="2">
- <title>外部配置参数</title>
- <tgroup cols="3">
- <colspec colname="c1" colnum="1"/>
- <colspec colname="c2" colnum="2"/>
- <colspec colname="c3" colnum="3"/>
- <thead>
- <row>
- <entry>参数名</entry>
- <entry>参数类型</entry>
- <entry>说明</entry>
- </row>
- </thead>
- <tbody>
- <row>
- <entry>SessionDefaultType</entry>
- <entry>String</entry>
- <entry>默认的会话类型</entry>
- </row>
- <row>
- <entry>UseTryLock</entry>
- <entry>Integer</entry>
- <entry>在规定的秒数内获得锁。如果不想使用这个功能，将它设为0或负数</entry>
- </row>
- </tbody>
- </tgroup>
- </table>
- </section>
- <section>
- <title>适配器内部（inbound）配置</title>
- <para>内部配置参数也应该保持不变。它们控制向MDB转发消息的各种属性。通过在MDB上添加相应的激活配置
- （activation configuration）可以覆盖这些参数的值。它可以用来配置一个MDB从另外一个服务器
- 接收消息。</para>
- <para>除了全局的配置参数外，内部的配置还定义了其它一些参数。</para>
-
- <table frame="topbot" border="2">
- <title>Inbound Configuration Properties</title>
- <tgroup cols="3">
- <colspec colname="c1" colnum="1"/>
- <colspec colname="c2" colnum="2"/>
- <colspec colname="c3" colnum="3"/>
- <thead>
- <row>
- <entry>参数名</entry>
- <entry>参数类型</entry>
- <entry>说明</entry>
- </row>
- </thead>
- <tbody>
- <row>
- <entry>Destination</entry>
- <entry>String</entry>
- <entry>目标的JNDI名字</entry>
- </row>
- <row>
- <entry>DestinationType</entry>
- <entry>String</entry>
- <entry>目标的类型，<literal>javax.jms.Queue</literal>或者<literal>javax.jms.Topic</literal>
- (默认是javax.jms.Queue)</entry>
- </row>
- <row>
- <entry>AcknowledgeMode</entry>
- <entry>String</entry>
- <entry>通知模式，<literal>Auto-acknowledge</literal> 或 <literal>Dups-ok-acknowledge</literal>
- (默认值是Auto-acknowledge). <literal>AUTO_ACKNOWLEDGE</literal>和<literal>DUPS_OK_ACKNOWLEDGE</literal>也是有效值</entry>
- </row>
- <row>
- <entry>MaxSession</entry>
- <entry>Integer</entry>
- <entry>内部配置创建的最大会话数（默认是5）</entry>
- </row>
- <row>
- <entry>MessageSelector</entry>
- <entry>String</entry>
- <entry>接收者的消息选择器</entry>
- </row>
- <row>
- <entry>SubscriptionDurability</entry>
- <entry>String</entry>
- <entry>订阅的类型，<literal>Durable</literal>或者<literal>NonDurable</literal></entry>
- </row>
- <row>
- <entry>SubscriptionName</entry>
- <entry>String</entry>
- <entry>订阅的名字</entry>
- </row>
- <row>
- <entry>TransactionTimeout</entry>
- <entry>Long</entry>
- <entry>事务超时（毫秒，默认是0，表示事务不会超时）</entry>
- </row>
- <row>
- <entry>UseJNDI</entry>
- <entry>Boolean</entry>
- <entry>是否使用JNDI来查找目标（默认是true）</entry>
- </row>
- </tbody>
- </tgroup>
- </table>
- </section>
- <section>
- <title>配置适配器访问单独的ActiveMQ服务器</title>
- <para>在有的情况下，消息服务器与应用服务器运行在不同的机器上。这时客户端只需要安装ActiveMQ的客户端的库文件。本节给出了具体的配置和所需要的jar文件。</para>
- <section>
- <para>你需要配置两个配置文件。一个是MDB所用的内部适配器，另一个是可以创建外部连接的外部适配器。</para>
- <section>
- <title>配置内部适配器</title>
- <para>首先在<literal>deploy</literal>目录下创建一个以.rar为结尾的文件夹。
- 在这里我们将其命名为<literal>activemq-ra.rar</literal>。主注意这一点很重要，因为MDB和外部配置都需要引用
- 该文件夹的名字。
- </para>
- <note>
- <para>在JBoss中该文件夹的默认名为<literal>jms-ra.rar</literal>。你可以直接使用这个名字。但是你可能需要避免
- 与其它的通用适配器相冲突。
- </para>
- </note>
- <para>在文件夹
- <literal>activemq-ra.rar</literal>
- 下创建名为
- <literal>META-INF</literal>
- 的文件夹，然后在些文件夹内创建一个
- <literal>ra.xml</literal>配置文件。在ActiveMQ发布包中
- 有一个<literal>ra.xml</literal>模板文件供你使用。
- </para>
- <para>要配置MDB接收远程ActiveMQ服务器的消息，你需要修改<literal>deploy/hornet-ra.rar/META-INF</literal>下面的
- <literal>ra.xml</literal>文件，将传输层改为netty连接器（不要使用invm连接器）及其相应的参数。下面
- 是一个配置的例子：
- </para>
-
- <programlisting>
- <resourceadapter-class>org.apache.activemq.ra.ActiveMQResourceAdapter</resourceadapter-class>
- <config-property>
- <description>The transport type</description>
- <config-property-name>ConnectorClassName</config-property-name>
- <config-property-type>java.lang.String</config-property-type>
- <config-property-value>org.apache.activemq.core.remoting.impl.netty.NettyConnectorFactory</config-property-value>
- </config-property>
- <config-property>
- <description>The transport configuration. These values must be in the form of key=val;key=val;</description>
- <config-property-name>ConnectionParameters</config-property-name>
- <config-property-type>java.lang.String</config-property-type>
- <config-property-value>host=127.0.0.1;port=5446</config-property-value>
- </config-property>
- </programlisting>
- <para>上面的配置中，适配器连接到一个运行在本机上端口为5446的服务器。</para>
- </section>
-
- <section>
- <title>配置外部适配器</title>
- <para>你还需要创建一个<literal>activemq-ds.xml</literal>文件来配置外部连接。该文件需要放置在<literal>deploy</literal>
- 下的任意一个文件夹中。在一相标准的安装中这个文件夹是<literal>horneq</literal> 或者 <literal>activemq.sar</literal>。
- 当然你可以选择其它文件夹。该文件的名字只要是以<literal>-ds.xml</literal>即可。在ActiveMQ的发布包中包含有一个模板文件，
- 它的名字是<literal>jms-ds.xml</literal>，位置就在config文件夹下。
- </para>
- <para>下面是一个配置的例子。</para>
- <programlisting>
- <tx-connection-factory>
- <jndi-name>RemoteJmsXA</jndi-name>
- <xa-transaction/>
- <rar-name>activemq-ra.rar</rar-name>
- <connection-definition>org.apache.activemq.ra.ActiveMQRAConnectionFactory</connection-definition>
- <config-property name="SessionDefaultType" type="java.lang.String">javax.jms.Topic</config-property>
- <config-property name="ConnectorClassName" type="java.lang.String">org.apache.activemq.core.remoting.impl.netty.NettyConnectorFactory</config-property>
- <config-property name="ConnectionParameters" type="java.lang.String">host=127.0.0.1;port=5446</config-property>
- <max-pool-size>20</max-pool-size>
- </tx-connection-factory>
- </programlisting>
- <para>这个配置同样是连接到运行在本机上的端口为5446的ActiveMQ服务器。JEE模块可以通过JNDI查找
- <literal>java:/RemoteJmsXA</literal>（由<literal>jndi-name</literal>参数定义）。如上节所述，
- 资源适配器根据文件夹下的配置来创建外部连接。</para>
- <section>
- <title>依赖的jar文件</title>
- <para>下面列出了ActiveMQ所需要的第三方jar文件</para>
- <table frame="topbot" border="2">
- <title>Jar文件</title>
- <tgroup cols="3">
- <colspec colname="c1" colnum="1"/>
- <colspec colname="c2" colnum="2"/>
- <colspec colname="c3" colnum="3"/>
- <thead>
- <row>
- <entry>Jar文件名</entry>
- <entry>说明</entry>
- <entry>位置</entry>
- </row>
- </thead>
- <tbody>
- <row>
- <entry>activemq-ra.jar</entry>
- <entry>ActiveMQ资源适配器文件</entry>
- <entry>deploy/activemq-ra.rar或相应的位置</entry>
- </row>
- <row>
- <entry>activemq-core-client.jar</entry>
- <entry>ActiveMQ核心客户类库</entry>
- <entry>在JBoss的default/lib下或者是$JBOSS_HOME/common/lib下。 </entry>
- </row>
- <row>
- <entry>activemq-jms-client.jar</entry>
- <entry>ActiveMQ的JMS类</entry>
- <entry>同上</entry>
- </row>
- <row>
- <entry>netty.jar</entry>
- <entry>Netty类库</entry>
- <entry>同上</entry>
- </row>
- </tbody>
- </tgroup>
- </table>
- </section>
- </section>
- </section>
- </section>
- <section>
- <title>高可获得性JNDI (HA-JNDI)</title>
- <para>采用JNDI来查找JMS对象时（队列，话题及连接工厂），使用HA－JNDI可以增加容错的能力。即当你正在使用
- 的JNDI服务器发生故障时，客户端可以使用集群中的其它JNDI服务器继续工作。</para>
- <para>HA-JNDI是JBoss应用服务器的一项服务，它为客户端提供JNDI服务，客户端无需知道JNDI具体服务器的连接
- 细节。这个服务只有在集群的JBoss应用服务器上才可使用。</para>
- <para>要使用HA－JNDI，需要使用下面的JNDI参数。</para>
- <programlisting>Hashtable<String, String> jndiParameters = new Hashtable<String, String>();
-jndiParameters.put("java.naming.factory.initial",
- "org.jnp.interfaces.NamingContextFactory");
-jndiParameters.put("java.naming.factory.url.pkgs=",
- "org.jboss.naming:org.jnp.interfaces");
-
-initialContext = new InitialContext(jndiParameters);</programlisting>
- <para>有关HA-JNDI更多的信息请参见<ulink
- url="http://www.jboss.org/file-access/default/members/jbossas/freezone/docs/Clustering_Guide/5/html/clustering-jndi.html"
- >JBoss应用服务器集群文档</ulink>。</para>
- </section>
- <section id="xa-recovery">
- <title>XA恢复</title>
- <para><emphasis>XA恢复</emphasis>解决的是事务在系统或应用出现故障时的处理。它可以保证在应用进程或主机出现故障
- 或网络崩溃等情况下，事务内所有资源的状态的一致性。有关XA恢复的更多信息请见 <ulink
- url="http://www.jboss.org/community/wiki/JBossTransactions">JBoss
- 事务</ulink>。</para>
- <para>当ActiveMQ与JBoss应用服务器集成时，它可以利用JBoss的事务处理来对消息资源进行恢复。如果消息处理包括
- 在一个XA事务中，如果服务器出现故障并重启时，恢复管理器将负责恢复事务，这样其中的消息要么被提交，要么被回滚（取
- 决于事务的处理决定）。</para>
- <section>
- <title>XA恢复的配置</title>
- <para>要想ActiveMQ具有XA恢复功能，则必须配置恢复管理器连接到ActiveMQ并恢复其资源。下面的参数必须要加到
- <literal>conf/jbossts-properties.xml</literal>文件中的<literal>jta</literal>部分:</para>
- <programlisting>
-<properties depends="arjuna" name="jta">
- ...
-
- <property name="com.arjuna.ats.jta.recovery.XAResourceRecovery.ActiveMQ1"
- value="org.apache.activemq.jms.server.recovery.ActiveMQXAResourceRecovery;[连接配置]"/>
-</properties>
- </programlisting>
- <para>其中<literal>[连接配置]</literal>包括连接ActiveMQ节点所必需的信息。
- 它的格式是<literal>[连接工厂类名],[用户名], [密码], [连接参数]</literal>。 </para>
- <itemizedlist>
- <listitem>
- <para><literal>[连接工厂类名]</literal>指的是<literal>ConnectorFactory</literal>
- 的类名，用来连接ActiveMQ服务器。其值可以是<literal
- >org.apache.activemq.core.remoting.impl.invm.InVMConnectorFactory</literal> 或
- <literal
- >org.apache.activemq.core.remoting.impl.netty.NettyConnectorFactory</literal></para>
- </listitem>
- <listitem>
- <para><literal>[用户名]</literal>是用于创建客户会话的用户名。是可选项。</para>
- </listitem>
- <listitem>
- <para><literal>[密码]</literal>是创建客户会话时所用的密码。只有在用户名存在时需要。</para>
- </listitem>
- <listitem>
- <para><literal>[连接参数]</literal> 是用逗号分隔的一串键－值对。它们会传递给连接器工厂
- （参见 <xref linkend="configuring-transports"/>）。</para>
- </listitem>
- </itemizedlist>
- <note>
- <para>ActiveMQ必须有一个与<literal>conf/jbossts-properties.xml</literal>中定义的连接器相对应的接受器（acceptor）。</para>
- </note>
- <section>
- <title>配置参数</title>
- <para>如果ActiveMQ配置了一个默认的in-vm接受器：</para>
- <programlisting>
-<acceptor name="in-vm">
- <factory-class>org.apache.activemq.core.remoting.impl.invm.InVMAcceptorFactory</factory-class>
-</acceptor>
- </programlisting>
- <para>相应地在 <literal
- >conf/jbossts-properties.xml</literal>文件中：</para>
- <programlisting>
-<property name="com.arjuna.ats.jta.recovery.XAResourceRecovery.HORNETQ1"
- value="org.apache.activemq.jms.server.recovery.ActiveMQXAResourceRecovery;org.apache.activemq.core.remoting.impl.invm.InVMConnectorFactory"/>
- </programlisting>
- <para>如果配置了一个netty接受器，并且端口不是默认的：</para>
- <programlisting>
-<acceptor name="netty">
- <factory-class>org.apache.activemq.core.remoting.impl.netty.NettyConnectorFactory</factory-class>
- <param key="port" value="8888"/>
-</acceptor>
- </programlisting>
- <para>相应的在 <literal
- >conf/jbossts-properties.xml</literal>文件中：</para>
- <programlisting>
-<property name="com.arjuna.ats.jta.recovery.XAResourceRecovery.HORNETQ1"
- value="org.apache.activemq.jms.server.recovery.ActiveMQXAResourceRecovery;org.apache.activemq.core.remoting.impl.netty.NettyConnectorFactory, , , port=8888"/>
- </programlisting>
- <note>
- <para>注意在没有用户名和密码时，逗号是不能省略的。</para>
- </note>
- <para>如果恢复必须要求是<literal>admin, adminpass</literal>，则其配置
- 应为如下所示：</para>
- <programlisting>
- <property name="com.arjuna.ats.jta.recovery.XAResourceRecovery.HORNETQ1"
- value="org.apache.activemq.jms.server.recovery.ActiveMQXAResourceRecovery;org.apache.activemq.core.remoting.impl.netty.NettyConnectorFactory, admin, adminpass, port=8888"/>
- </programlisting>
- <para>推荐在XA恢复中，将ActiveMQ配置一个invm接受器，并配置恢复管理器使用invm连接器。</para>
- </section>
- </section>
- <section>
- <title>例子</title>
- <para>参见<xref linkend="xa-recovery-example"/>。这个例子展示了如何来配置XA恢复以便在服务器崩溃后恢复消息。</para>
- </section>
- </section>
- </section>
-</chapter>
http://git-wip-us.apache.org/repos/asf/activemq-6/blob/d18c42b0/docs/user-manual/zh/architecture.xml
----------------------------------------------------------------------
diff --git a/docs/user-manual/zh/architecture.xml b/docs/user-manual/zh/architecture.xml
deleted file mode 100644
index 6cb0f1a..0000000
--- a/docs/user-manual/zh/architecture.xml
+++ /dev/null
@@ -1,95 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!-- ============================================================================= -->
-<!-- Copyright © 2009 Red Hat, Inc. and others. -->
-<!-- -->
-<!-- The text of and illustrations in this document are licensed by Red Hat under -->
-<!-- a Creative Commons Attribution–Share Alike 3.0 Unported license ("CC-BY-SA"). -->
-<!-- -->
-<!-- An explanation of CC-BY-SA is available at -->
-<!-- -->
-<!-- http://creativecommons.org/licenses/by-sa/3.0/. -->
-<!-- -->
-<!-- In accordance with CC-BY-SA, if you distribute this document or an adaptation -->
-<!-- of it, you must provide the URL for the original version. -->
-<!-- -->
-<!-- Red Hat, as the licensor of this document, waives the right to enforce, -->
-<!-- and agrees not to assert, Section 4d of CC-BY-SA to the fullest extent -->
-<!-- permitted by applicable law. -->
-<!-- ============================================================================= -->
-<chapter id="architecture">
- <title>总体架构</title>
- <para>本章对ActiveMQ的总体技术架构进行了概括描述。</para>
- <section>
- <title>核心架构</title>
- <para>ActiveMQ的核心是由一组简单Java对象（POJO）构成的。同时在设计ActiveMQ时将对外部jar包的依赖降到最低限度。
- 实际上ActiveMQ的核心部分只有一个外部依赖，就是netty.jar。ActiveMQ使用了其中的用于缓冲的一些类。
- 我们相信这样的理念应该受到用户的欢迎。</para>
- <para>由于依赖性很小，ActiveMQ可以非常容易地嵌入到其它应用中，或者加入到一些依赖注入式的框架中，
- 如JBoss Microcontainer，Spring或Google Guice。</para>
- <para>每个ActiveMQ服务器都有自己的超高性能的持久日志（journal）用于消息和其它信息的持久化。</para>
- <para>采用这种独特的高效日志要比采用普通数据库作为持久层的系统拥有更高的性能。</para>
- <para>通常情况下分布在不同物理机器上的客户端同时访问ActiveMQ服务器。目前ActiveMQ提供了两套API供客户端使用：</para>
- <para>
- <orderedlist>
- <listitem>
- <para>核心API。这是一组普通的Java接口，用它可以访问ActiveMQ的全部功能。</para>
- </listitem>
- <listitem>
- <para>JMS客户端API。这是标准的JMS API。</para>
- </listitem>
- </orderedlist>
- </para>
- <para>实际上JMS API是在核心API的外部加上一层简单的封装。</para>
- <para>在ActiveMQ内核是没有JMS的，这样设计的目的是为了支持多个协议。</para>
- <para>当客户端通过JMS接口访问ActiveMQ时，所有JMS的操作都被转换成相应的核心API，然后将请求以ActiveMQ格式发向服务器。</para>
- <para>ActiveMQ服务器只接收核心API的访问。</para>
- <para>图3.1描述了这些操作。</para>
- <para>
- <graphic fileref="images/architecture1.jpg" align="center"/>
- </para>
- <para>在图3.1中示出了两个用户访问ActiveMQ服务器。用户1使用JMS API，用户2使用的是核心API。</para>
- <para>图中清楚的展示出了JMS是如何通过封装（facade）转化为核心API的。</para>
- </section>
- <section>
- <title>将ActiveMQ嵌入到你的应用程序中</title>
- <para>如果你的应用程序内部需要消息服务，但同时你又不想将消息服务暴露为单独的ActiveMQ服务器，你可以在应用中直接将ActiveMQ实例化。</para>
- <para>有关嵌入式ActiveMQ的详细信息请参阅 <xref linkend="embedding-activemq"
- />。</para>
- </section>
- <section>
- <title>将ActiveMQ与JEE应用服务器集成</title>
- <para>ActiveMQ提供了标准的JCA适配器，利用它可以将ActiveMQ轻松地集成到任何一个符合JEE规范的应用服务器或servlet容器中。</para>
- <para>JEE应用服务品提供了消息Bean（MDB）用于处理来自外部的消息，比如来自JMS系统或邮件系统的消息。</para>
- <para>最常见的应用应该是用MDB来接收来自JMS系统中的消息了。在JEE规范中规定了JEE应用服务器使用JCA adaptor与JMS消息系统集成，
- MDB通过这个adaptor来接收消息。</para>
- <para>JCA adaptor不仅可以用来接收消息，还可以用来从EJB或servlet中向外部的JMS发送消息。在JEE应用服务器中应该用JCA adaptor与JMS系统进行交互。
- 实际上JEE规范中不允许在JEE服务器中不通过JCA而直接访问JMS系统。</para>
- <para>在EJB中使用消息往往需要连接池或交易，而JCA可以提供这方面的服务，无需额外的开发任务。当然直接访问JMS系统是可能的，
- 但是你将不能利用JCA所提供的这些有用的功能，因此我们不建议使用直接访问的方式。</para>
- <para>图3.2给出了ActiveMQ通过JCA adaptor与JEE应用服务器集成的示意图。图中可以看出所有的交互都通过JCA adaptor。</para>
- <para>图中带有禁止符号的箭头表明的是从EJB会话Bean直接访问ActiveMQ的情况。由于不通过JCA，这种方法往往造成每次EJB访问ActiveMQ都要新建一个连接和会话，
- 使效率大降低。这被视为反设计模式（anti-pattern）。</para>
- <para>
- <graphic fileref="images/architecture2.jpg"/>
- </para>
- <para><xref linkend="appserver-integration"/>对如何使用JCA给出了更加详细的描述。</para>
- </section>
- <section>
- <title>ActiveMQ作为独立的服务（standalone）</title>
- <para>ActiveMQ可以部署成为独立的服务器。它可运行于任何JEE应用服务器之外，作为一个独立的服务运行。
- 作为独立服务器运行时，ActiveMQ消息服务器包括一个核心服务器，一个JMS服务以及一个JNDI服务。</para>
- <para>JMS服务用来部署服务器端<literal>activemq-jms.xml</literal>配置文件中的JMS Queue，Topic和ConnectionFactory实例。
- 此外它还提供一组简单的管理接口，通过这些接口可以创建、消毁（destroy）Queue，Topic和ConnectionFactory实例。
- 用于可以通过JMX或连接使用这些接口。JMS服务是单独的服务，它不是ActiveMQ核心服务。ActiveMQ的核心不包含JMS相关的服务。
- 如果你不需要通过服务器端的xml配置文件部署任何JMS对象，也不需要JMS的管理接口，你可以选择不启动该服务。</para>
- <para>启动JNDI服务的目的是因为JMS需要通过JNDI来获得Queue，Topic以及ConnectionFactory。如果不需要，也可以选择不启动该服务。</para>
- <para>ActiveMQ允许在客户端程序中通过编程来直接创建各种JMS对象和核心对象来代替JNDI查找，所以JNDI不是必需的。
- ActiveMQ采用JBoss Microcontainer来引导并实例化服务，并保证模块之间的依赖关系。JBoss Microcontainer是一个轻量级的POJO引导器（bootstrapper）。</para>
- <para>图3.3给出了ActiveMQ独立服务器的架构。</para>
- <para>
- <graphic fileref="images/architecture3.jpg"/>
- </para>
- <para>相关配置的相关信息可以在第<xref
- linkend="server.configuration"/>找到。$ </para>
- </section>
-</chapter>
http://git-wip-us.apache.org/repos/asf/activemq-6/blob/d18c42b0/docs/user-manual/zh/client-classpath.xml
----------------------------------------------------------------------
diff --git a/docs/user-manual/zh/client-classpath.xml b/docs/user-manual/zh/client-classpath.xml
deleted file mode 100644
index ee85330..0000000
--- a/docs/user-manual/zh/client-classpath.xml
+++ /dev/null
@@ -1,47 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!-- ============================================================================= -->
-<!-- Copyright © 2009 Red Hat, Inc. and others. -->
-<!-- -->
-<!-- The text of and illustrations in this document are licensed by Red Hat under -->
-<!-- a Creative Commons Attribution–Share Alike 3.0 Unported license ("CC-BY-SA"). -->
-<!-- -->
-<!-- An explanation of CC-BY-SA is available at -->
-<!-- -->
-<!-- http://creativecommons.org/licenses/by-sa/3.0/. -->
-<!-- -->
-<!-- In accordance with CC-BY-SA, if you distribute this document or an adaptation -->
-<!-- of it, you must provide the URL for the original version. -->
-<!-- -->
-<!-- Red Hat, as the licensor of this document, waives the right to enforce, -->
-<!-- and agrees not to assert, Section 4d of CC-BY-SA to the fullest extent -->
-<!-- permitted by applicable law. -->
-<!-- ============================================================================= -->
-<chapter id="client-classpath">
- <title>客户端的Classpath</title>
- <para>ActiveMQ的<emphasis>客户端Classpath</emphasis>需要有几个jar文件。具体是哪几个要根据客户端
- 是需要内核API、JMS和JNDI中的哪些服务来确定。</para>
- <warning>
- <para>本章所提及的所有jar文件全部在HorneQ发布包的 <literal>lib</literal>目录下。在使用中一定
- 要确保所有的jar文件属于同一个发布版本。将不同版本的jar混在一起使用可能造成一些难以发现的错误。</para>
- </warning>
- <section>
- <title>使用ActiveMQ内核的客户端</title>
- <para>如果客户端只使用ActiveMQ内核（非JMS客户端），需要将 <literal
- >activemq-core-client.jar</literal>和
- <literal>netty.jar</literal> 放到classpath中。</para>
- </section>
- <section>
- <title>JMS客户端</title>
- <para>如果客户端使用JMS，需要在classpath上增加两个jar文件： <literal
- >activemq-jms-client.jar</literal> 和 <literal>jboss-jms-api.jar</literal>。</para>
- <note>
- <para><literal>jboss-jms-api.jar</literal>中包含的只是 <literal>javax.jms.*</literal> 包中的接口类。
- 如果这些类已经在你的classpath中，则你就不需要这个jar文件。</para>
- </note>
- </section>
- <section>
- <title>需要JNDI的JMS客户端</title>
- <para>如果你的JMS客户端使用JNDI来查找ActiveMQ单独服务器上的对象，你需要将 <literal>jnp-client.jar</literal> 增加
- 到你的classpath中。</para>
- </section>
-</chapter>
http://git-wip-us.apache.org/repos/asf/activemq-6/blob/d18c42b0/docs/user-manual/zh/client-reconnection.xml
----------------------------------------------------------------------
diff --git a/docs/user-manual/zh/client-reconnection.xml b/docs/user-manual/zh/client-reconnection.xml
deleted file mode 100644
index ae50e97..0000000
--- a/docs/user-manual/zh/client-reconnection.xml
+++ /dev/null
@@ -1,116 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!-- ============================================================================= -->
-<!-- Copyright © 2009 Red Hat, Inc. and others. -->
-<!-- -->
-<!-- The text of and illustrations in this document are licensed by Red Hat under -->
-<!-- a Creative Commons Attribution–Share Alike 3.0 Unported license ("CC-BY-SA"). -->
-<!-- -->
-<!-- An explanation of CC-BY-SA is available at -->
-<!-- -->
-<!-- http://creativecommons.org/licenses/by-sa/3.0/. -->
-<!-- -->
-<!-- In accordance with CC-BY-SA, if you distribute this document or an adaptation -->
-<!-- of it, you must provide the URL for the original version. -->
-<!-- -->
-<!-- Red Hat, as the licensor of this document, waives the right to enforce, -->
-<!-- and agrees not to assert, Section 4d of CC-BY-SA to the fullest extent -->
-<!-- permitted by applicable law. -->
-<!-- ============================================================================= -->
-<chapter id="client-reconnection">
- <title>客户端重新连接与会话恢复</title>
- <para>通过配置，ActiveMQ的客户端在与服务器的连接出现故障时，可以自动地重新建立连接并恢复与服务器的通迅。</para>
- <section>
- <title>100%透明的会话恢复（re-attachment）</title>
- <para>如果网络出现暂时性连接故障，并且服务器没有重启的情况下，当前的会话还会存在服务器中，其状态如同客户端
- 没有断开超过连接TTL<xref linkend="connection-ttl"/>时间。</para>
- <para>在这种情况下，当客户端重新连接上服务器后，ActiveMQ自动将客户端和会话与服务器端的会话重新连接起来。整个过程
- 对于客户端是完全透明的，在客户端就好像什么都没有发生一样。</para>
- <para>具体工作原理如下：</para>
- <para>客户端再向服务器发送命令时，它将每个命令保存到内存的一块缓存中。当连接出现故障时客户端会尝试与该服务
- 器恢复会话。做为恢复协议的一部分，服务器在会话恢复时通知客户端最后一个成功接收的命令id。</para>
- <para>根据这个命令id，客户端可以判断它的缓存中是否有命令还未被服务器成功接收。如果有，客户端可以重新发送
- 这些命令。</para>
- <para>缓存的大小由<literal>ConfirmationWindowSize</literal>参数决定。当服务器成功接收了
- <literal>ConfirmationWindowSize</literal>字节的命令时，会向客户端发送一个命令确认，以使客户端
- 及时清除缓存。</para>
- <para>如果使用JMS服务，并且JMS的连接工厂是注册到JNDI的话，相应的参数是<literal
- >activemq-jms.xml</literal>文件中的<literal
- >confirmation-window-size</literal>项。如果你并不将JMS连接工厂注册到JNDI，则你需要在
- <literal>ActiveMQConnectionFactory</literal>上使用相应的方法直接设置该参数。</para>
- <para>如果使用核心服务，你可以直接在<literal>ClientSessionFactory</literal>实例上直接设置该参数。</para>
- <para>参数的单位是字节。</para>
- <para>如果该参数是值设为<literal>-1</literal>，则关闭缓存，即关闭了重新恢复功能，迫使进行重新连接。默认
- 值是<literal>-1</literal>（表示没有自动恢复）。</para>
- </section>
- <section>
- <title>会话重新连接</title>
- <para>有时服务器发生故障后进行了重启。这时服务器将丢失所有当前的会话，上面所述的会话恢复就不能做到完全透明了。</para>
- <para>在这种情况下，ActiveMQ自动地重新建立连接并<emphasis role="italic">重新创建</emphasis>会话
- 和接收者。这一过程与向备份服务器进行失效备援（failover）完全一样。</para>
- <para>客户重新连接的功能还用在其它一些模块上，如核心桥，以使它们能够重新连接到目标服务器上。</para>
- <para>要全面理解事务性会话和非事务性会话在失效备援／重连接情况下的细节，以及如何保证<emphasis role="italic">
- 一次并且只有一次</emphasis>的消息传递，请参见<xref linkend="ha.automatic.failover"/>的有关内容。</para>
- </section>
- <section>
- <title>重新连接／会话恢复的配置参数</title>
- <para>下面是客户端用于重新连接的参数：</para>
- <itemizedlist>
- <listitem>
- <para><literal>retry-interval</literal>。可选参数。它决定了两次重新连接尝试间隔的时间。单位
- 是毫秒。默认值是<literal>2000</literal>毫秒。</para>
- </listitem>
- <listitem>
- <para><literal>retry-interval-multiplier</literal>。可选参数。它表示下一次重试时间间隔的
- 系数。即下一次重试的时间间隔是本次时间间隔乘以该参数。</para>
- <para>这样可以实现重试间隔的<emphasis>指数延迟（exponential backoff）</emphasis>。</para>
- <para>让我们看一个例子：</para>
- <para>假设<literal>retry-interval</literal>为<literal>1000</literal> ms，并且我们
- 将<literal>retry-interval-multiplier</literal>设为<literal>2.0</literal>，如果
- 第一次尝试失败，则等待<literal>1000</literal>毫秒后进行第二次重试，如果再失败，则每三次重
- 试要在<literal>2000</literal>毫秒后进行，第四次要等待<literal>4000</literal>毫秒，
- 以此类推。</para>
- <para>默认值是<literal>1.0</literal>，表示每次重试间隔相同的时间。</para>
- </listitem>
- <listitem>
- <para><literal>max-retry-interval</literal>。可选参数。它决定了重试间的最大时间间隔。
- 使用<literal>retry-interval-multiplier</literal>可以使重试的时间间隔以指数级增加。
- 有可能造成时间间隔增加到一个非常大的数值。通过设置一个最大值可对其增长进行限制。默认
- 值是<literal>2000</literal>毫秒。</para>
- </listitem>
- <listitem>
- <para><literal>reconnect-attempts</literal>。可选参数。它表示要进行多少重试后才放弃
- 并退出。<literal>-1</literal>表示进行无限次重试。默认值是<literal>0</literal>。</para>
- </listitem>
- </itemizedlist>
- <para>如果使用JMS并且将JMS的连接工厂绑定到JNDI服务中，则需要在<literal>activemq-jms.xml</literal>
- 文件中对这些参数进行配置，如下例所示：</para>
- <programlisting>
-<connection-factory name="ConnectionFactory">
-<connectors>
- <connector-ref connector-name="netty"/>
-</connectors>
-<entries>
- <entry name="ConnectionFactory"/>
- <entry name="XAConnectionFactory"/>
-</entries>
-<retry-interval>1000</retry-interval>
-<retry-interval-multiplier>1.5</retry-interval-multiplier>
-<max-retry-interval>60000</max-retry-interval>
-<reconnect-attempts>1000</reconnect-attempts>
-</connection-factory>
- </programlisting>
- <para>如果使用JMS但是直接实例化JMS连接工厂，你可以使用适当的方法在 <literal
- >ActiveMQConnectionFactory</literal> 对象上直接设置这些参数。</para>
- <para>如果使用核心接口直接创建 <literal
- >ClientSessionFactory</literal>实例，则用它的适当的方法可以设置这些参数。</para>
- <para>如果客户端重新连接后发现会话已经丢失（如服务器重启或超时），则无法完成恢复。如果在连接上或会话上注册了
- <literal>ExceptionListener</literal>或<literal>FailureListener</literal>，
- 它们将会被通知。</para>
- </section>
- <section id="client-reconnection.exceptionlistener">
- <title>ExceptionListeners and SessionFailureListeners</title>
- <para>请注意当客户端进行重新连接或恢复会话时，注册的JMS <literal
- >ExceptionListener</literal> 或核心接口的 <literal>SessionFailureListener</literal>
- 将会被调用。</para>
- </section>
-</chapter>