app_serverthread.java

福建鑫诺话机客户端接受程序

package telproject;

import java.io.*;
import java.net.*;
import java.util.*;
import java.lang.*;

public class App_ServerThread extends Pub_MyRunnable {

	private InetAddress clinent_ip = null;

	private Queue_Socket[] socket_queue = null;

	private int iCurPutQueue = 0;

	private ServerSocket server = null;

	public App_ServerThread(Queue_Socket[] q1) {
		socket_queue = q1;
	}

	protected void end() {
	}

	public synchronized void run() {
		try {
			if (server != null) {
				server.close();
			}
			server = new ServerSocket(Pub_ReadXML.monitorPort);
			System.out.println("--[监听模块]连接服务器端口成功--");
		} catch (Exception e) {
			System.out.println("--[监听模块]连接服务器端口失败...");
			e.printStackTrace();
		}
		try {
			while (true) {
				resetIdle();
				Socket s = server.accept();
				if (s != null) {
					socket_queue[iCurPutQueue].push(s);
					System.out.println("--[监听模块]收到Socket请求，放入处理队列号="
							+ (iCurPutQueue + 1));
					iCurPutQueue++;
					if (iCurPutQueue >= 10)
						iCurPutQueue = 0;
				}
			}
		} catch (Exception e) {
			System.out.println("--[监听模块]处理Socket请求异常--");
			e.printStackTrace();
		}
	}
}