2. 程式人生 > >Mule ESB java元件兩種寫法

Mule ESB java元件兩種寫法

阿新 • • 發佈：2019-02-13

先說1. 
說到底就是一個訊息的轉換功能， 就是獲取到http請求過來的訊息(payload), 然後將其轉換為自己後續需要的格式的資料形態。 
Java程式碼  收藏程式碼
  1. import java.io.ByteArrayOutputStream;  
  2. import java.io.IOException;  
  3. import java.io.InputStream;  
  4. import java.util.HashMap;  
  5. import java.util.Map;  
  6. import javax.activation.DataHandler;  
  7. import org.mule.api.MuleEventContext;  
  8. import org.mule.api.MuleMessage;  
  9. import org.mule.api.lifecycle.Callable;  
  10. public class Transformer implements Callable  {  
  11.     @Override  
  12.     public Object onCall(MuleEventContext eventContext) throws Exception {  
  13.         // TODO Auto-generated method stub  
  14.         MuleMessage message  = eventContext.getMessage();  
  15.         //message.getPayload()得到的是通過Httpclient-MultipartEntity傳過來的二進位制流  
  16.         System.out.println(message.getPayload());  
  17.         InputStream in = (InputStream) message.getPayload();  
  18.         ByteArrayOutputStream bstream = new ByteArrayOutputStream();    
  19.         byte[] buff = new byte[100];    
  20.         int
     rc = 0;  
  21.         try {  
  22.             while ((rc = in.read(buff, 0, 100)) > 0) {    
  23.                 bstream.write(buff, 0, rc);    
  24.             }  
  25.         } catch (IOException e) {  
  26.             e.printStackTrace();  
  27.         }    
  28.         byte[] bytes = bstream.toByteArray();    
  29.         System.out.println("-------------------------111--" + bytes);  
  30.         //httpClient addPart傳過來的StringBody  
  31.         System.out.println(message.getInboundAttachmentNames());  
  32.         DataHandler h1 = message.getInboundAttachment("serviceId");  
  33.         DataHandler h2 =  message.getInboundAttachment("fileName");  
  34.         System.out.println("------------------------------------");  
  35.         Map map = new HashMap();  
  36.         map.put("serviceId", h1.getContent().toString());  
  37.         map.put("fileName", h2.getContent().toString());  
  38.         map.put("payload", bytes);  
  39.         return map;  
  40.     }  
  41. }  


將http post過來的兩個字串引數 和 一個檔案byte流 轉換為 map形式， 目的是因為http傳過來的是 multipart/form-data ， 而後面的框架程式碼要同時相容application/x-www-form-urlencoded , 所以統一進行轉換 

實現Callable 介面， 取得MuleEventContext上下文，進而獲取MuleMessage。 
其中getPayload()得到了 inputstream ， 獲取檔案位元組陣列， 通過getInboundAttachment("serviceId") 獲取到StringBody、 
直接返回訊息例項 


2. component 
目的是改變訊息set到MuleEvent ，返回event 

Java程式碼  收藏程式碼
  1. import java.io.ByteArrayOutputStream;  
  2. import java.io.IOException;  
  3. import java.io.InputStream;  
  4. import java.util.HashMap;  
  5. import java.util.Map;  
  6. import javax.activation.DataHandler;  
  7. import org.mule.api.MuleEvent;  
  8. import org.mule.api.MuleException;  
  9. import org.mule.api.MuleMessage;  
  10. import org.mule.api.processor.MessageProcessor;  
  11. public class MutipartTransformer implements MessageProcessor  {  
  12.     @Override  
  13.     public MuleEvent process(MuleEvent event) throws MuleException {  
  14.         MuleMessage mulemessage = event.getMessage();  
  15.         InputStream in = (InputStream) mulemessage.getPayload();  
  16.         ByteArrayOutputStream bstream = new ByteArrayOutputStream();    
  17.         byte[] buff = new byte[100];    
  18.         int rc = 0;  
  19.         try {  
  20.             while ((rc = in.read(buff, 0, 100)) > 0) {    
  21.                 bstream.write(buff, 0, rc);    
  22.             }  
  23.         } catch (IOException e) {  
  24.             e.printStackTrace();  
  25.         }    
  26.         byte[] bytes = bstream.toByteArray();    
  27.         System.out.println(mulemessage.getInboundAttachmentNames());  
  28.         DataHandler h1 = mulemessage.getInboundAttachment("serviceId");  
  29.         DataHandler h2 =  mulemessage.getInboundAttachment("fileName");  
  30.         try {  
  31.             System.out.println(h1.getContent().toString());  
  32.         } catch (IOException e) {  
  33.             e.printStackTrace();  
  34.         }  
  35.         try {  
  36.             System.out.println(h2.getContent().toString());  
  37.         } catch (IOException e) {  
  38.             // TODO Auto-generated catch block  
  39.             e.printStackTrace();  
  40.         }  
  41.         System.out.println("bbbbbbbbbbbbbbbbbbbbbbbbb    ");  
  42.         Map map = new HashMap();  
  43.         map.put("serviceId", h1);  
  44.         map.put("fileName", h2);  
  45.         map.put("payload", bytes);  
  46.         event.setMessage(mulemessage);  
  47.         return event;  
  48.     }  
  49. }  

相關推薦

Mule ESB java元件兩種寫法

先說1. 說到底就是一個訊息的轉換功能， 就是獲取到http請求過來的訊息(payload), 然後將其轉換為自己後續需要的格式的資料形態。  Java程式碼   import java.io.ByteArrayOutputStream;   import java.io.IOException;  

java路徑兩種寫法"/"和"\"

linu 分隔 環境 存在 平臺 配置文件 ava window 寫法 1.示例： String path="D:\\新建文件夾\\2.png"; File file=new File(path); System.out.println(file.exis

java路徑兩種寫法"/"和"\\"以及 ./和../以及/之間的區別？

String path="D:\\新建資料夾\\2.png";     File file=new File(path);     System.out.println(file.exists());  &n

java路徑兩種寫法"/"和"\\"

java<span style="color: rgb(51, 51, 51); font-family: Arial; font-size: 14px; line-height: 26px;">程式碼中 兩種路徑符號的寫法</span>String

React Native 元件的預設屬性Props的兩種寫法

首先是ES5 的寫法  是通過 getDefaultProps(){ return {duration:1000} } ES 6 的寫法如下： static defaultProps = { duration:1000, }

HDU 2102 A計劃 DFS與BFS兩種寫法

blog ons bsp 求解 stream eof node 耗時 {} 1.題意：一位公主被困在迷宮裏，一位勇士前去營救，迷宮為兩層，規模為N*M，迷宮入口為(0,0,0),公主的位置用‘P‘標記；迷宮內，‘.‘表示空地，‘*‘表示墻，特殊的，‘#‘表示時空傳輸機，走到

es6對象內函數的兩種寫法

images style image class cti window對象 ima nbsp 方法 es6對象內函數一般有兩種寫法: var person1 = { name: "p1", sayThis() { console.log(t

CSS中`nav ul li ul` 與 `nav>ul>li` 這兩種寫法的區別是什麽

class apach pac 順序 code nbsp ron 例如 選擇 >是指只能一代接一代，比如： nav>ul>li>ul>li，必須是下面這樣的 <nav> <

LCA的兩種寫法

blank mes col tarjan include pri for namespace continue 第一種是離線的Tarjan算法 #include<cstdio> using namespace std; int rd(){ int x=

java excel兩種操作方式

我們 網上 class 工作 use 列數 args println sheet 原文https://www.cnblogs.com/wangyang108/p/6030420.html Excel是我們平時工作中比較常用的用於存儲二維表數據的，JAVA也可以直接對Exce

java的兩種選擇結構

enum clas 必須 else if 特點 控制 情況 () 第一個 選擇結構: If結構： 結構： 　　　　　　　　if(){： //功能語句 }else if(){

關於MyBatis的兩種寫法

spa sdn 得到 ctu art 動態代理 ike blog 解析xml 剛接觸MyBatis是在Jike的視頻中學習的，但是之後又發現和項目中的MyBatis的用法不太一致。上網找了好多資料，發現網上的教程分為兩種寫法： 第一種，是jike視頻中的寫法，寫好map.x

Java getResource兩種使用方式

ati 打印 ssl ren classes println tex mac pre 1、新建一個Java項目； 2、在src/main/java下新建一個test包； 3、在test包下新建一個Test.java文件 和 file.txt 文件； 4、Test.java文

java的兩種同步方式， Synchronized與ReentrantLock的區別

性能 避免 字節碼 數據 獲取對象 通過 finall 內核 構造函數 java在編寫多線程程序時，為了保證線程安全，需要對數據同步，經常用到兩種同步方式就是Synchronized和重入鎖ReentrantLock。 相似點： 這兩種同步方式有很多相似之

controller 有兩種寫法，討論一下兩種寫法的區別：

controller 有兩種寫法，討論一下兩種寫法的區別： 寫法 1： app.controller('myCtrl', function($scope, $location) { $scope.myUrl = $location.absUrl(); }); 寫法2： app.controller('

線段樹的兩種寫法

void change(int t,int l,int r,int x,int y,int v){ /*if (x<=l && r<=y){ mn[t]=lazy[t]=v; return; } down(t); if (x<=mid) ch

ajax的兩種寫法總結

   ajax不是一種新的程式語言，而是使用JavaScript向伺服器提出請求並處理而不阻塞使用者，核心物件時XMLHTTPRequest,可以在不重新整理頁面的前提下進行區域性重新整理（使用非同步資料重新整理），使使用者的體驗更好，伺服器的壓力更小。 一.原生的a

android SplashActivity的兩種寫法

記錄SplashActivity的簡單用法，重要在思路 倒計時式（在UI顯示倒計時） 使用靜態處理和弱引用的方式防止記憶體洩漏 處理器的SendMessage函式傳送第一次訊息（索引） 之後再的handleMessage中接受並處理訊息（再次傳送，一個迴圈進行的）和UI更新 im

Java中兩種比較器的實現

程式輸出結果：  為了讓大家較全，我把結果拷貝下來，如下：  通過內部比較器實現：  [id:1,salary=4500.0, id:2,salary=5000.0, id:4,salary=3500.0, id:4,salary=4000.0, id:5,salary=3000.0]  通過外部比較器實現：

shell指令碼檔案中for迴圈的兩種寫法

#!/bin/bash for (( i = 0; i <= 10; i++ )) ; do echo "The value is: $i" done echo -e "\nJourneys end in lovers' meeting."