socketserverservice.java.svn-base

梦界家园程序开发基底框架

package jm.net.sv;

import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;

import jm.net.common.CommonKeys;
import jm.util.JMRpcThread;

/**
 * <p>Title: JM</p>
 *
 * <p>Copyright: Copyright (c) 2004-2006</p>
 *
 * <p>Company: 1SHome</p>
 *
 * <p>@author Spook</p>
 *
 * @version 1.2.5.2
 * @see JDK 1.5.0.6
 */
public class SocketServerService extends JMRpcThread implements CommonKeys{
    final String CLASS_NAME = "SocketServerService";

    private ServerSocket serverSocket_ = null;
    int Port_ = 0;
    public SocketServerService (int port) {
        Port_ = port;
    }

    /**
     * 打开通信端口
     * @return
     */
    public synchronized boolean openServer () {
        try {
            serverSocket_ = new ServerSocket(Port_);
            start();
            return true;
        } catch (Exception ex) {
            return false;
        }
    }
    public InetAddress getIPAddress(){
    	return serverSocket_.getInetAddress();
    }
    
	public void setConnectBufferSize(int size) {
		size_ = size;
	}

	int size_ = SIZE_1K;
	
    public void run () {
        //final String sMethod = "run";
        Socket _clinetSocket = null;
        SocketServerThread _serverThread = null;
        while (true) {
            try {
                if(serverSocket_ == null||serverSocket_.isClosed()){
                    this.interrupt();
                    return;
                }
                _clinetSocket = serverSocket_.accept();
                if (_clinetSocket != null) {
                    _serverThread = new SocketServerThread(_clinetSocket);
                    _serverThread.setConnectBufferSize(size_);
                    Thread.sleep(1000);
                    _serverThread = null;
                }
            } catch (Exception ex) {
                _serverThread = null;
                serverSocket_ = null;
                return;
            }
        }
    }
    
    /**
     * 关闭通信端口
     * @return
     */
    public synchronized boolean closeServer () {
        //final String sMethod = "close";
        try {
            if (serverSocket_ != null) {
                serverSocket_.close();
                serverSocket_ = null;
            }
        } catch (Exception ex) {
            serverSocket_ = null;
            return false;
        }
        return true;
    }
}