?? recivedata.java
字號:
package com.sunyard.dataanalyze;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;
import java.util.HashMap;
import java.util.Map;
public class ReciveData extends Thread {
private DatagramSocket socket = null;
private int port = PackageConstants.LISTEN_PORT;
public ReciveData(){
try {
socket = new DatagramSocket(port);
} catch (SocketException e) {
e.printStackTrace();
}
}
public static void main(String args[]){
}
public void run(){
DatagramPacket p = null;
Destination dest = new Destination();
byte[] bt = new byte[1024*5];
try{
byte[] buf = new byte[socket.getReceiveBufferSize()];
p = new DatagramPacket(buf, buf.length);
} catch (SocketException e){
e.printStackTrace();
}
while(true){
try{
socket.receive(p);
bt = p.getData();
String str = new String(bt);
//System.out.println(str);
String[] strs = str.split(PackageConstants.PACKAGE_SPLIT_STR);
//Package pkg = new Package(str);
Map content = new HashMap();
String tradeNo = "";
for(int i=0; i<strs.length; i++){
if(!strs[i].trim().equals("")){
Package pkg = new Package(strs[i]);
//content = pkg.getContent();
Map tempContent = pkg.getContent();
content.putAll(tempContent);//包體內容
tradeNo = pkg.getTradeNo();//交易碼
PackageConstants.log.info("接收數據包---"+"交易碼:"+pkg.getTradeNo()+",流水號:"+tempContent.get("SerSeqNo"));
}
}
SendDataPacket sdp = new SendDataPacket();
sdp.send(content, tradeNo, dest.getIp(), dest.getPort());
//String tradeNo = pkg.getTradeNo();
InsertAction action = new InsertAction();
//Map fieldMapping = action.findFieldMapByTradeNo(tradeNo);
//action.action(tradeNo, content);
sleep(100);
}catch(IOException e){
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -