OSDN -- 开发和下载开源软件
简体中文翻译状态 translation status for zh
edit | Title Index |  Recent Changes  | 

Scheduler実装サービス jp.ossc.nimbus.service.scheduler2.JMSSchedulerService

jp.ossc.nimbus.service.scheduler2.JMSSchedulerServiceは、スケジュールをJMS Queueを使って非同期処理するScheduler実装サービスです。

このスケジューラは、DefaultSchedulerServiceがQueueを使って、スケジュールを監視して投入する監視スレッドと、スケジュールを実行するスレッドをわけて、スケジュールを非同期に処理しているのに対して、NimbusのQueueの代わりにJMS Queueを使用しています。
JMS Queueを使用する事で、Queue自体を永続化する事が可能になるため、耐障害性を向上させる事ができます。

このサービスは、複合的なサービスで、以下のサービスを下位サービスとして使用します。

下位サービスインタフェース用途
jp.ossc.nimbus.service.scheduler2.ScheduleManager実行すべきスケジュールを取得する。
jp.ossc.nimbus.service.scheduler2.ScheduleExecutorスケジュールの実行を依頼する。
jp.ossc.nimbus.service.keepalive.ClusterServiceスケジューラをクラスタ化する。
jp.ossc.nimbus.service.sequence.Sequenceスケジュールの処理通番を発行する。
jp.ossc.nimbus.service.context.ThreadContextServiceスケジュールの処理通番を設定する。
jp.ossc.nimbus.service.transaction.TransactionManagerFactoryjavax.transaction.TransactionManagerを取得する
jp.ossc.nimbus.service.jms.JMSSessionFactoryJMS Queueに接続するためのJMS Sessionを作成する。
jp.ossc.nimbus.service.jms.JMSMessageProducerFactoryJMS Queueに投入するためのJMS MessageProducerを作成する。
jp.ossc.nimbus.service.jms.JMSMessageConsumerFactoryJMS Queueから受信するためのJMS MessageConsumerを作成する。

以下に簡単なサービス定義を示します。 

  1.  <?xml version="1.0" encoding="Shift_JIS"?>
  2.  <!DOCTYPE server PUBLIC
  3.    "-//Nimbus//DTD Nimbus 1.0//JA"
  4.    "http://nimbus.sourceforge.jp/dtd/nimbus-service_1_0.dtd">
  5.  
  6.  <server>
  7.      
  8.      <manager>
  9.          
  10.          <!-- スケジューラサービス -->
  11.          <service name="Scheduler"
  12.                   code="jp.ossc.nimbus.service.scheduler2.JMSSchedulerService">
  13.              
  14.              <!-- ScheduleManagerサービスのサービス名を設定する -->
  15.              <attribute name="ScheduleManagerServiceName">#ScheduleManager</attribute>
  16.              
  17.              <!-- ScheduleExecutorサービスのサービス名を設定する -->
  18.              <attribute name="ScheduleExecutorServiceName">#ScheduleExecutor</attribute>
  19.              
  20.              <!-- JMSSessionFactoryサービスのサービス名を設定する -->
  21.              <attribute name="JMSSessionFactoryServiceName">#XAJMSSessionFactory</attribute>
  22.              
  23.              <!-- JMSMessageProducerFactoryサービスのサービス名を設定する -->
  24.              <attribute name="JMSMessageProducerFactoryServiceName">#XAJMSMessageProducerFactory</attribute>
  25.              
  26.              <!-- JMSMessageConsumerFactoryサービスのサービス名を設定する -->
  27.              <attribute name="JMSMessageConsumerFactoryServiceName">#JMSMessageConsumerFactory</attribute>
  28.              
  29.              <!-- JMS Queueからスケジュールを受信するスレッド数を設定する -->
  30.              <attribute name="MessageConsumerSize">3</attribute>
  31.              
  32.              <!-- トランザクション制御を有効にするを設定する -->
  33.              <attribute name="TransactionControl">true</attribute>
  34.              
  35.              <!-- JMSのMessageの配信モードを永続化に設定する -->
  36.              <attribute name="DeliveryMode" >
  37.                  <static-field-ref code="javax.jms.DeliveryMode" name="PERSISTENT"/>
  38.              </attribute>
  39.              
  40.              <depends>ScheduleExecutor</depends>
  41.              <depends>ScheduleManager</depends>
  42.              <depends>XAJMSSessionFactory</depends>
  43.              <depends>XAJMSMessageProducerFactory</depends>
  44.              <depends>JMSMessageConsumerFactory</depends>
  45.          </service>
  46.          
  47.          <!-- ScheduleManagerサービス -->
  48.          <service name="ScheduleManager"
  49.                   code="jp.ossc.nimbus.service.scheduler2.DefaultScheduleManagerService">
  50.              <attribute name="ScheduleMasterServiceNames">
  51.                  #ScheduleMaster1
  52.                  #ScheduleMaster2
  53.                  #ScheduleMaster3
  54.                  #ScheduleMaster4
  55.              </attribute>
  56.              <attribute name="PersistDir">./schedule</attribute>
  57.              <depends>
  58.                  <!-- スケジュールマスタ1
  59.                      08:00:00にFlow1を実行するスケジュール
  60.                  -->
  61.                  <service name="ScheduleMaster1"
  62.                           code="jp.ossc.nimbus.service.scheduler2.DefaultScheduleMaster">
  63.                      <attribute name="Id">Schedule1</attribute>
  64.                      <attribute name="TaskName">Flow1</attribute>
  65.                      <attribute name="StartTime">// 08:00:00 000</attribute>
  66.                  </service>
  67.              </depends>
  68.              <depends>
  69.                  <!-- スケジュールマスタ2
  70.                      スケジュールマスタ1の終了を待って、08:00:00にFlow2を実行するスケジュール
  71.                  -->
  72.                  <service name="ScheduleMaster2"
  73.                           code="jp.ossc.nimbus.service.scheduler2.DefaultScheduleMaster">
  74.                      <attribute name="Id">Schedule2</attribute>
  75.                      <attribute name="TaskName">Flow2</attribute>
  76.                      <attribute name="StartTime">// 08:00:00 000</attribute>
  77.                      <attribute name="Input">100</attribute>
  78.                      <attribute name="Depends">Schedule1</attribute>
  79.                  </service>
  80.              </depends>
  81.              <depends>
  82.                  <!-- スケジュールマスタ3
  83.                      スケジュールマスタ2の終了を待って、08:01:00から08:02:00まで5秒間隔にFlow3を実行するスケジュール
  84.                  -->
  85.                  <service name="ScheduleMaster3"
  86.                           code="jp.ossc.nimbus.service.scheduler2.DefaultScheduleMaster">
  87.                      <attribute name="Id">Schedule3</attribute>
  88.                      <attribute name="TaskName">Flow3</attribute>
  89.                      <attribute name="StartTime">// 08:01:00 000</attribute>
  90.                      <attribute name="EndTime">// 08:02:00 000</attribute>
  91.                      <attribute name="RepeatInterval">5000</attribute>
  92.                      <attribute name="Depends">Schedule2</attribute>
  93.                  </service>
  94.              </depends>
  95.              <depends>
  96.                  <!-- スケジュールマスタ4
  97.                      スケジュールマスタ1とスケジュールマスタ3の終了を待って、08:00:00から08:03:00までFlow4の結果でリトライを指示される限り、10秒間隔でFlow4を実行するスケジュール
  98.                      08:03:00に達しても、リトライを指示された場合は、エラー終了する
  99.                  -->
  100.                  <service name="ScheduleMaster4"
  101.                           code="jp.ossc.nimbus.service.scheduler2.DefaultScheduleMaster">
  102.                      <attribute name="Id">Schedule4</attribute>
  103.                      <attribute name="TaskName">Flow4</attribute>
  104.                      <attribute name="StartTime">// 08:00:00 000</attribute>
  105.                      <attribute name="Depends">Schedule1,Schedule3</attribute>
  106.                      <attribute name="RetryInterval">10000</attribute>
  107.                      <attribute name="RetryEndTime">// 08:03:00 000</attribute>
  108.                  </service>
  109.              </depends>
  110.              
  111.          </service>
  112.          
  113.          <!-- ScheduleExecuterサービス -->
  114.          <service name="ScheduleExecutor"
  115.                   code="jp.ossc.nimbus.service.scheduler2.BeanFlowScheduleExecutorService">
  116.              <attribute name="ScheduleManagerServiceName">#ScheduleManager</attribute>
  117.              <attribute name="BeanFlowInvokerFactoryServiceName">#BeanFlowInvokerFactory</attribute>
  118.              <depends>ScheduleManager</depends>
  119.              <depends>BeanFlowInvokerFactory</depends>
  120.          </service>
  121.          
  122.          <!-- BeanFlowInvokerを生成するBeanFlowInvokerFactoryサービス -->
  123.          <service name="BeanFlowInvokerFactory"
  124.                   code="jp.ossc.nimbus.service.beancontrol.DefaultBeanFlowInvokerFactoryService">
  125.              <attribute name="DirPaths">flows</attribute>
  126.              <attribute name="BeanFlowInvokerAccessClass">jp.ossc.nimbus.service.beancontrol.BeanFlowInvokerAccessImpl2</attribute>
  127.              <attribute name="Validate">true</attribute>
  128.          </service>
  129.          
  130.          <!-- Queueへの投入を行うMessageProducerを取得するJMSMessageProducerFactoryサービス -->
  131.          <service name="JMSMessageProducerFactory"
  132.                   code="jp.ossc.nimbus.service.jms.JMSQueueSenderFactoryService">
  133.              <attribute name="DestinationFinderServiceName">#LocalJndiFinder</attribute>
  134.              <attribute name="DestinationName">queue/ScheduleQueue</attribute>
  135.              <depends>LocalJndiFinder</depends>
  136.          </service>
  137.          
  138.          <!-- Queueへの投入時に使用するセッションを生成するJMSSessionFactoryサービス -->
  139.          <service name="XAJMSSessionFactory"
  140.                   code="jp.ossc.nimbus.service.jms.JMSQueueSessionFactoryService">
  141.              <attribute name="TransactionMode">true</attribute>
  142.              <attribute name="JMSConnectionFactoryServiceName">#XAJMSConnectionFactory</attribute>
  143.              <depends>XAJMSConnectionFactoryr</depends>
  144.          </service>
  145.  
  146.          <!-- Queueへの投入時に使用するQueueConnectionを生成するJMSConnectionFactoryサービス -->
  147.          <service name="XAJMSConnectionFactory"
  148.                   code="jp.ossc.nimbus.service.jms.JMSQueueConnectionFactoryService">
  149.              <attribute name="JndiFinderServiceName">#LocalJndiFinder</attribute>
  150.              <attribute name="ConnectionFactoryName">java:/JmsXA</attribute>
  151.              <depends>LocalJndiFinder</depends>
  152.          </service>
  153.          
  154.          <!-- Queueからの受信を行うMessageConsumerを生成するJMSMessageConsumerFactoryサービス -->
  155.          <service name="JMSMessageConsumerFactory"
  156.                   code="jp.ossc.nimbus.service.jms.JMSQueueReceiverFactoryService">
  157.              <attribute name="JMSSessionFactoryServiceName">#JMSSessionFactory</attribute>
  158.              <attribute name="DestinationFinderServiceName">#LocalJndiFinder</attribute>
  159.              <attribute name="DestinationName">queue/ScheduleQueue</attribute>
  160.              <depends>JMSSessionFactory</depends>
  161.              <depends>LocalJndiFinder</depends>
  162.          </service>
  163.          
  164.          <!-- Queueからの受信時に使用するセッションを取得するJMSSessionFactoryサービスうける -->
  165.          <service name="JMSSessionFactory"
  166.                   code="jp.ossc.nimbus.service.jms.JMSQueueSessionFactoryService">
  167.              <attribute name="TransactionMode">false</attribute>
  168.              <attribute name="JMSConnectionFactoryServiceName">#JMSConnectionFactory</attribute>
  169.              <depends>JMSConnectionFactory</depends>
  170.          </service>
  171.  
  172.          <!-- Queueからの受信するためのQueueConnectionを取得するJMSConnectionFactoryサービス -->
  173.          <service name="JMSConnectionFactory"
  174.                   code="jp.ossc.nimbus.service.jms.JMSQueueConnectionFactoryService">
  175.              <attribute name="JndiFinderServiceName">#LocalJndiFinder</attribute>
  176.              <attribute name="ConnectionFactoryName">java:/XAConnectionFactory</attribute>
  177.              <depends>LocalJndiFinder</depends>
  178.          </service>
  179.  
  180.          <!--JndiFinderサービス-->
  181.          <service name="LocalJndiFinder"
  182.                   code="jp.ossc.nimbus.service.jndi.CachedJndiFinderService"/>
  183.          
  184.      </manager>
  185.      
  186.  </server>

スケジューラ/高機能スケジューラ/Scheduler

edit history delete
config

[PageInfo]  LastUpdate: 2014-03-07 16:24:45, ModifiedBy: m-takata
[Permissions]  view:all, edit:members, delete/config:doc editors
[IRI]  https://zh.osdn.net/projects/nimbus/wiki/Function/service/scheduler2/JMSSchedulerService