acquisitionserver.java

基于SOCKET的文件传输,软件平台为JAVA

/**
 * 
 */
package com.sincere.utils.timer;

import java.net.*;
import java.util.Date;

/**
 * @author Administrator
 * 信息采集服务器
 */
public class AcquisitionServer extends Thread {
	
	private boolean alive 	= true;	//控制服务器是否正常工作
	private int intPort		= 0;	//默认端口
	private long countNum 	= 0;	//判断服务器接收Socket会话总数
	private String strSavePath = "";//保存路径

	/**
	 * 构造方法
	 * @param intPort		指定监听端口
	 * @param strSavePath	解压文件保存路径
	 */
	public AcquisitionServer(int intPort, String strSavePath){
		super();
		this.intPort = intPort;
		this.strSavePath = strSavePath;
	}
	
	/* (non-Javadoc)
	 * @see java.lang.Thread#run()
	 */
	@Override
	public void run() {
		ServerSocket serverSocket;
		try{
			serverSocket = new ServerSocket((intPort<0)? 7777:intPort);
			while(alive){
				Socket s = serverSocket.accept();
				//如果获取的Socket会话为空,则退出信息采集
				if(s == null){
					alive = false;
					break;
				}
				//计数增加
				countNum++;
				
				InformationProcessing ip = new InformationProcessing(s, strSavePath);
				ip.start();
			}
			serverSocket.close();
		}catch(Exception e){
			System.out.println(">>>信息采集服务器发生异常"+new Date().toString());
			e.printStackTrace();
		}finally{
			System.out.println("<<<信息采集服务器关闭"+new Date().toString());
		}
	}

	/* (non-Javadoc)
	 * @see java.lang.Thread#start()
	 */
	@Override
	public synchronized void start() {
		// TODO Auto-generated method stub
		super.start();
		System.out.println(">>>信息采集服务器启动"+new Date().toString());
	}

}