?? recivemessage.java
字號:
package com.sunyard.dataanalyze.message;
import java.io.BufferedInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class ReciveMessage extends Thread{
private ServerSocket serverSocket = null;
private int messagePort;
public ReciveMessage(int port){
messagePort = port;
try{
serverSocket = new ServerSocket(messagePort);
}catch(IOException e){
}
}
public void run(){
while(true){
try {
Socket socket = serverSocket.accept();
byte[] bt = new byte[512];
ByteArrayOutputStream stream = new ByteArrayOutputStream();
InputStream inputStream = socket.getInputStream();
int ch = 0;
BufferedInputStream buf = new BufferedInputStream(inputStream);
while((ch=buf.read(bt))!=-1){
stream.write(bt, 0, ch);
}
String recive = stream.toString();
Message message = new Message();
message.parseMessage(recive.toString());
switch(message.getMessageType()){
case MessageConstants.MESSAGE_SERVER:
System.out.println("服務(wù)改變報文");
break;
case MessageConstants.MESSAGE_STATE:
System.out.println("狀態(tài)改變報文");
break;
case MessageConstants.MESSAGE_ERROR:
System.out.println("報文格式錯誤!");
break;
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
?? 快捷鍵說明
復(fù)制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -