Spring Integration基本用法

關於spring-integration的介紹這裡不需要贅述，現在我們需要實現的是傳送乙個param,裡面有兩個引數datatype和data,datatype是0和1除外的捨棄，剩餘datatype=0的資料往oldchannel通道發，剩餘datatype=1的資料往newchannel通道發，消費資料並且列印

public class splitservice extends abstractmessagesplitter 

param param = (param)msg.getpayload();
if(param.getdatatype !=0 || param.getdatatype !=1) 
//可以重新對param進行處理後再返回
return param;
}}

public class param 

public integer getdata() 
public void setdatatype(integer datatype) 
public void setdata(object data) 
}

/**

路由重定向
*/public class routerservice 
if(param.getdatatype==1) 
return "oldchannel";
}}

public class doconsumerservice

public void printnewmsg(param param) 
}

public class main else 

param.setdata("");
messagemsg = messagebuilder.withpayload(param).build();
msgchannel.send(msg);}}
}

Spring Integration學習筆記二

三 message channel詳述 message channel用來將多個訊息端點 message endpoint 連線在一起，message channel可以保障訊息可以安全的在多個訊息端點 message endpoint 之間進行收發。為了message channel可以更容易的和...

Spring Integration學習筆記 簡介

本文是自己學習的總結筆記，主要學習資料如下。唉，到了新公司，發現公司用的是spring integration框架，被迫學習。學習資料實在太少，integration系列的學習筆記的參考資料基本都在自與官方文件，有些部分都是在翻譯文件內容。spring integration也是spring 全家桶...

elastic search head 基本用法

elastic search head 基本用法 es 安裝方法 資源監控和集群管理外掛程式 bin plugin install lukas vlcek bigdesk 資料查詢外掛程式 bin plugin install mobz elasticsearch head 理解性 index 類似...