本文主要介紹weblogic jms的配置，包括JMS 伺服器和JMS 模組（連線工廠、佇列、遠端 SAF 上下文、SAF 匯入目的地、SAF 錯誤處理）的配置；並在Spring環境下進行訊息的監聽及傳送；為了更多的使用webloigc jms的功能，傳送的佇列使用saf配置的遠端weblogic jms佇列（兩邊的weblogic版本須一致），當然本地也是可以的。本文中demo所使用的軟體環境為：weblogic 10.3.6.0、spring5.1.2.RELEASE

注：saf配置的遠端佇列只能傳送訊息，不能監聽訊息。

1、weblogic jms配置

1.1、配置JMS 伺服器

注：需配置永續性儲存，沒有就建立一個

1.2、配置JMS 模組

下面的功能都是在JMS 模組中配置；連線工廠、佇列、遠端 SAF 上下文、SAF 匯入目的地、SAF 錯誤處理

這裡就不一一截圖配置過程了，按頁面提示配置就行；配置結果如下

連線工廠需設定jndi,程式裡會用到

SAF 遠端上下文配置的遠端地址及使用者名稱密碼資訊

SAF 匯入目的地配置的遠端的佇列訊息及對應到本地的jndi

SAF 錯誤處理程式配置錯誤處理策略屬性,選配

佇列需設定jndi,程式裡會用到

SAF 匯入目的地配置的佇列訊息如下：

點選佇列名稱：

本地 JNDI 名稱程式裡會用到，向該jndi傳送訊息實際會發送到遠端的佇列裡。

2、spring配置

增加applicationContext-jms.xml檔案：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
  xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
  xmlns:security="http://www.springframework.org/schema/security"
  xmlns:task="http://www.springframework.org/schema/task"
  xsi:schemaLocation="http://www.springframework.org/schema/beans
            http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
            http://www.springframework.org/schema/aop
            http://www.springframework.org/schema/aop/spring-aop-4.3.xsd
            http://www.springframework.org/schema/tx
            http://www.springframework.org/schema/tx/spring-tx-4.3.xsd
            http://www.springframework.org/schema/context
            http://www.springframework.org/schema/context/spring-context-4.3.xsd
            http://www.springframework.org/schema/security
            http://www.springframework.org/schema/security/spring-security-4.3.xsd
            http://www.springframework.org/schema/task
            http://www.springframework.org/schema/task/spring-task-4.3.xsd">

  <bean id="jndiTemplate" class="org.springframework.jndi.JndiTemplate">
    <property name="environment">
      <props>
        <prop key="java.naming.factory.initial">weblogic.jndi.WLInitialContextFactory</prop>
        <prop key="java.naming.provider.url">t3://10.39.196.10:7001</prop>
        <prop key="java.naming.security.principal">weblogic</prop>
        <prop key="java.naming.security.credentials">weblogic1</prop>
      </props>
    </property>
  </bean>
  <bean id="jmsConnectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean">
    <property name="jndiTemplate" ref="jndiTemplate" />
    <property name="proxyInterface" value="javax.jms.ConnectionFactory" />
    <property name="jndiName" value="ConnectionFactory-test" />
  </bean>
  <bean id="testQueueSend" class="org.springframework.jndi.JndiObjectFactoryBean">
    <property name="jndiName" value="testQueueSend" />
    <property name="jndiTemplate" ref="jndiTemplate" />
  </bean>
  <bean id="testQueueReceive" class="org.springframework.jndi.JndiObjectFactoryBean">
    <property name="jndiName" value="testQueue" />
    <property name="jndiTemplate" ref="jndiTemplate" />
  </bean>
  <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory" ref="jmsConnectionFactory" />
  </bean>

  <bean id="sender" class="com.inspur.demo.jms.Sender">
  </bean>
  <task:scheduled-tasks>
    <task:scheduled ref="sender" method="hello" cron="0/5 * * * * ?" />
  </task:scheduled-tasks>
  <bean id="receiver" class="com.inspur.demo.jms.Receiver">
  </bean>
  <bean id="listenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
    <property name="connectionFactory" ref="jmsConnectionFactory" />
    <property name="destination" ref="testQueueReceive" />
    <property name="messageListener" ref="receiver" />
    <property name="autoStartup" value="true" />
  </bean>
</beans>

jndiTemplate配置weblogic的連線資訊

jmsConnectionFactory配置連線工廠

testQueueSend向該佇列傳送訊息，對應上面saf遠端目的地裡佇列的本地jndi名稱，

testQueueReceive對該佇列進行監聽，接受訊息

jmsTemplate配置jms的模板

sender傳送訊息的類，把該類配置為定時任務，定時傳送訊息；

receiver監聽的類

listenerContainer監聽容器

3、類資訊

傳送者：

package com.inspur.demo.jms;

import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;

public class Sender {
  protected static Logger logger = LoggerFactory.getLogger(Sender.class);
  
  //傳送訊息的佇列
  @Autowired
  @Qualifier("testQueueSend")
  private Destination destination;
  
  @Autowired
  private JmsTemplate jmsTemplate;
  
  public void hello() {
    String message = System.currentTimeMillis() + "-hello";
    logger.info("Message Send:{}",message);
    jmsTemplate.send(destination,new MessageCreator() {
      @Override
      public Message createMessage(Session session) throws JMSException {
        return session.createTextMessage(message);
      }
    });
  }
}

使用JmsTemplate來發送訊息。

接受者：

package com.inspur.demo.jms;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class Receiver implements MessageListener {
  protected static Logger logger = LoggerFactory.getLogger(Receiver.class);
  
  @Override
  public void onMessage(Message message) {
    try {
      String text = "";  
      if (message instanceof TextMessage) {  
        text = ((TextMessage) message).getText();  
      } 
      logger.info("Message received:{}",text);
    } catch (JMSException e) {
      e.printStackTrace();
    }
  }
}

4、測試

1.傳送訊息

啟動程式後，每隔5秒中會往testQueueSend佇列（遠端佇列）中傳送一條訊息，可到weblogic控制檯檢視訊息.

2.接受訊息

在weblogic控制檯手工往testQueueReceive佇列插入一條訊息，程式日誌會列印該訊息內容。

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支援我們。