當前位置：首頁 > 编程资源 > 编程问答 >内容正文

编程问答

使用Camel从WildFly 8向WebLogic 12发送JMS消息

發布時間：2023/12/3 编程问答 37 豆豆

生活随笔收集整理的這篇文章主要介紹了使用Camel从WildFly 8向WebLogic 12发送JMS消息小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

系統集成是一個很好的挑戰。特別是當您在尋找通信標準和可靠的解決方案時。在當今的微服務世界中，每個人都在談論REST服務和基于http的協議。實際上，對于大多數企業項目來說，這往往是遠遠不夠的，而這些項目通常具有更復雜的要求。合理的解決方案是基于Java消息服務的集成。而且，盡管我們不再關注集中式基礎架構和ESB，但我們希望為定義的服務提供基于點對點的集成。讓我們看看我們是否可以使其工作并在JBoss WildFly和Oracle WebLogic Server之間發送消息。

業務案例–從Java EE到微服務

但我想先退一步：為什么要有人？我認為，這種情況背后的主要動機之一是遷移路徑緩慢。從單一的單一平臺應用程序一直到最后，我們希望具有足夠的靈活性以將那些大型安裝中的單個服務封裝起來，并使它們作為服務可用。假設這是可能的，并且舊版應用程序具有不錯的設計。或者我們想提高個性化服務，從技術角度來說。在這個特定的示例中，我們迫不及待地想將Java EE 7功能引入我們的應用程序，而WebLogic仍然主要停留在EE 6上。我們可以使用REST服務甚至WebServices來做到這一點，但我們可能還需要更多。這就是JMS規范的來源。

WildFly中的Oracle JMS客戶端庫

為了在兩個不同的服務器之間發送消息，您需要將各個客戶端庫集成到發送端。對于WebLogic，這是WebLogic JMS瘦客戶端（wljmsclient.jar）。與WebLogic Install或Full客戶端相比，使用較小的客戶端資源提供了Java EE和WebLogic JMS功能，而與Thin T3客戶端相比，其提供的客戶端資源也較小。實際上，它包含Java EE JMS API和實現，它們將直接與WildFly提供的實現發生沖突。要使用它們，我們必須將它們打包為一個模塊，并在HornetQ中配置一個JMS Bridge來使用它。首先是添加新模塊。將文件夾更改為wildfly-8.2.0.Final \ modules \ system \ layers \ base并創建一個新的文件夾結構：custom \ oracle \ weblogic \ main在其下方。從此處的％MW_HOME％\ server \ lib文件夾復制wlthint3client.jar。現在，您必須添加一個模塊描述符文件，module.xml：

該文件定義了所有必需的資源和依賴項以及相關的排除項。如果完成了，我們最終需要消息橋。

HornetQ JMS消息橋

JMS橋的功能是使用來自源JMS目標的消息，并將其發送到目標JMS目標。通常，源或目標目標位于不同的服務器上。只要它們兼容JMS 1.1，該橋接器還可用于橋接來自其他非HornetQ JMS服務器的消息。打開standalone-full.xml并將以下配置添加到消息傳遞子系統：

<jms-bridge name="wls-bridge" module="custom.oracle.weblogic"><source><connection-factory name="java:/ConnectionFactory"/><destination name="java:/jms/sourceQ"/></source><target><connection-factory name="jms/WFMessagesCF"/><destination name="jms/WFMessages"/><context><property key="java.naming.factory.initial"value="weblogic.jndi.WLInitialContextFactory"/><property key="java.naming.provider.url"?value="t3://127.0.0.1:7001"/></context></target><quality-of-service>AT_MOST_ONCE</quality-of-service><failure-retry-interval>2000</failure-retry-interval><max-retries>10</max-retries><max-batch-size>500</max-batch-size><max-batch-time>500</max-batch-time><add-messageID-in-header>true</add-messageID-in-header></jms-bridge>

如您所見，它直接引用模塊，并具有源和目標定義。源是在消息收發子系統中定義的WildFly本地消息隊列：

<jms-queue name="sourceQ"><entry name="java:/jms/sourceQ"/></jms-queue>

而目標是在WebLogic Server中定義的遠程隊列以及連接工廠。我假設您知道該怎么做，否則請參閱本文檔。就是這樣。現在，我們需要向本地隊列發送一條消息，而該消息將通過網橋發送到WebLogic隊列。

測試橋–使用駱駝

將消息驅動的bean部署到WebLogic（是的，您必須將其作為ejb jar打包到耳朵中，所有這些）。這個特定的示例只是將消息文本轉儲到記錄器中。

@MessageDriven(mappedName = "jms/WFMessages", activationConfig = {@ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue") })public class LogMessageBean implements MessageListener {private final static Logger LOGGER = Logger.getLogger(LogMessageBean.class.getName());public LogMessageBean() {}@Overridepublic void onMessage(Message message) {TextMessage text = (TextMessage) message;try {LOGGER.log(Level.INFO, text.getText());} catch (JMSException jmxe) {LOGGER.log(Level.SEVERE, jmxe.getMessage());}} }

現在，我們需要WildFly服務器上的生產者。這樣做，我實際上是在使用WildFly-Camel JMS集成。

@Startup @ApplicationScoped @ContextName("jms-camel-context") public class JMSRouteBuilder extends RouteBuilder {@Overridepublic void configure() throws Exception {// Initial Context LookupContext ic = new InitialContext();ConnectionFactory cf = (ConnectionFactory) ic.lookup("/ConnectionFactory");// Create the JMS ComponentJmsComponent component = new JmsComponent();component.setConnectionFactory(cf);getContext().addComponent("jms", component);// Build A JSON GreetingJsonObject text = Json.createObjectBuilder().add("Greeting", "From WildFly 8").build();// Send a Message from timer to Queuefrom("timer://sendJMSMessage?fixedRate=true.=10000").transform(constant(text.toString())).to("jms:queue:sourceQ").log("JMS Message sent");} }

這就是整個魔術。計時器將JSON文本消息發送到本地隊列，該消息將橋接到WebLogic。

總結

以上是生活随笔為你收集整理的使用Camel从WildFly 8向WebLogic 12发送JMS消息的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。

上一篇： [笔记]三维激光SLAM学习——LiDA
下一篇：如何免费下载道客巴巴文档