Netty与ActiveMQ的程序代码范例

package tw.com.cathaybk.vmdirecttrace; import java.io.File; import java.nio.file.Paths; import java.text.DateFormat; import java.text.SimpleDateFormat; import java.util.Calendar; import java.util.Date; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.MessageListener; import javax.jms.TextMessage; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.mail.MailSender; import org.springframework.mail.SimpleMailMessage; import tw.com.cathaybk.util.MailAgent; import TR2DataSendClient.Sender; import TR2DataSendClient.Data.Form; public class MessageDefaultConsumer implements MessageListener { protected String forwardPort = ""; protected String forwardIP = ""; Logger logger = LoggerFactory.getLogger(getClass()); @Override public void onMessage(Message message) { if (message instanceof TextMessage) { try { DateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss,SSS"); Date today = Calendar.getInstance().getTime(); String procDate = df.format(today); String msg = ((TextMessage) message).getText() + "$_"; // 若不加，則後面空字串都不會被算入 Array 中。 String[] AfterSplit = msg.split("#"); if (AfterSplit.length == 50) { logger.info("recv : " + msg + " at " + procDate); Form obj = new Form(); obj.setLogYy( AfterSplit[0].contains("$")?AfterSplit[0].substring(AfterSplit[0].indexOf("$")+1):AfterSplit[0] ); obj.setLogMm( AfterSplit[1] ); obj.setLogDd( AfterSplit[2] ); obj.setLogSeq( AfterSplit[3] ); obj.setCrdFiid( AfterSplit[4] ); obj.setTranDat( AfterSplit[5] ); obj.setCrdNum( AfterSplit[6] ); obj.setRetlId( AfterSplit[7] ); obj.setTermId( AfterSplit[8] ); obj.setBatchNum( AfterSplit[9] ); obj.setRecTyp( AfterSplit[10] ); obj.setShiftNum( AfterSplit[11] ); obj.setSeqNum( AfterSplit[12] ); obj.setTranTim( AfterSplit[13] ); obj.setApprvCde8( AfterSplit[14] ); obj.setDftCapFlg( AfterSplit[15] ); obj.setTc( AfterSplit[16] ); obj.setCrdTyp( AfterSplit[17] ); //obj.setAmt1( AfterSplit[18].substring(0, 14) + "." + AfterSplit[18].substring(14)); // NUMERIC(16,2)，前14位為整數，後兩位為小數位。 //obj.setAmt2( AfterSplit[19].substring(0, 14) + "." + AfterSplit[19].substring(14) ); // NUMERIC(16,2)，前14位為整數，後兩位為小數位。 obj.setAmt1( AfterSplit[18]); obj.setAmt2( AfterSplit[19]); //obj.setAmt1("1000"); //obj.setAmt2("0"); obj.setAuthTyp( AfterSplit[20] ); obj.setOriginator( AfterSplit[21] ); obj.setResponder( AfterSplit[22] ); obj.setEntryTim( AfterSplit[23] ); obj.setExitTim( AfterSplit[24] ); obj.setReEntryTim( AfterSplit[25] ); obj.setTermCntryCde( AfterSplit[26] ); obj.setGrp( AfterSplit[27] ); obj.setUserId( AfterSplit[28] ); obj.setRetlSicCde( AfterSplit[29] ); obj.setOrig( AfterSplit[30] ); obj.setRespCde( AfterSplit[31] ); obj.setTrack2Fmt1( AfterSplit[32] ); obj.setPtSrvEntryMde( AfterSplit[33] ); obj.setOptnRetlId( AfterSplit[34] ); obj.setOptnEdcTc( AfterSplit[35] ); obj.setCardLn( AfterSplit[36] ); obj.setTermLn( AfterSplit[37] ); obj.setPtSrvCondMde( AfterSplit[38] ); obj.setTrack2ExpDate( AfterSplit[39] ); obj.setGmtDat( AfterSplit[40] ); obj.setGmtTim( AfterSplit[41] ); obj.setInDate( AfterSplit[42] ); obj.setUcafAuthnCollInd( AfterSplit[43] ); obj.setTxIndr( AfterSplit[44] ); obj.setAcctNumInd( AfterSplit[45] ); obj.setVirtualCardNum( AfterSplit[46] ); obj.setVcnExp( AfterSplit[47] ); obj.setOnBehalfService( AfterSplit[48] ); obj.setOnBehalfResult( AfterSplit[49].replace("$_", "") ); //Sender sd = new Sender( "127.0.0.1", "5210", getClass().getClassLoader().getResource("clientPass/tclient.keystore").getFile(), "tclient" ); // 在Eclipse 環境中使用 //logger.info("ready to send: " + forwardIP + ":" + forwardPort + " with keystore=" + getClass().getClassLoader().getResource("clientPass/tclient.keystore").getFile() ); //Sender sd = new Sender( forwardIP, forwardPort, getClass().getClassLoader().getResource("clientPass/tclient.keystore").getFile(), "tclient" ); //Sender sd = new Sender( forwardIP, forwardPort, "C:/Application/MIDNTX2501/Bin/vmdt/clientPass/tclient.keystore", "tclient" ); //logger.info("ready to send: " + forwardIP + ":" + forwardPort + " with keystore=" + new File("clientPass/tclient.keystore").getAbsolutePath() ); // 在包成 jar 檔的 環境中使用 //logger.info("ready to send: " + forwardIP + ":" + forwardPort + " with keystore=" + new File("clientPass/tclient.keystore").getAbsolutePath() ); //Sender sd = new Sender( forwardIP, forwardPort, new File("clientPass/tclient.keystore").getAbsolutePath(), "tclient" ); // 改設定在 server.properties 中 Sender sd = new Sender( forwardIP, forwardPort, keystorePath, "tclient" ); // "C:/D/Java/workspace/VMDirectTrace/bin/clientPass/tclient.keystore" String result = sd.send2Server(obj); if (!"".equals(result)) { mailAgent.sendMsg("VMDT 錯誤訊息", "傳送錯誤：" + result); } logger.info("send: " + obj.toString() + ", ret = " + result + " at " + df.format(Calendar.getInstance().getTime())); } else { logger.info("recv : " + msg + " at " + procDate + " but data error."); mailAgent.sendMsg("VMDT 錯誤訊息", "傳送錯誤：資料格式有誤：" + msg); } /* String msg = ((TextMessage) message).getText(); System.out.println("Message has been consumed : " + msg + " at " + procDate); Thread.sleep(5000); procDate = df.format(Calendar.getInstance().getTime()); System.out.println("Message has been processed : " + msg + " at " + procDate); */ } catch (JMSException ex) { mailAgent.sendMsg("VMDT 錯誤訊息", "傳送錯誤：JMSException：" + ex.getMessage()); //throw new RuntimeException(ex); } catch (Exception e) { mailAgent.sendMsg("VMDT 錯誤訊息", "傳送錯誤：Exception：" + e.getMessage()); logger.info("Exception : " + e.getMessage()); } } else { throw new IllegalArgumentException( "Message must be of type TextMessage"); } } public String getForwardIP() { return forwardIP; } public void setForwardIP(String forwardIP) { this.forwardIP = forwardIP; } public String getForwardPort() { return forwardPort; } public void setForwardPort(String forwardPort) { this.forwardPort = forwardPort; } private String keystorePath; public void setKeystorePath(String keystorePath) { this.keystorePath = keystorePath; } private MailAgent mailAgent; public void setMailAgent(MailAgent mailAgent) { this.mailAgent =