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();
			}
		}
	}
}