myserver.java~8~

JBuilder实现的具有单机

package Server;


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


public class MyServer extends Thread
{


    final int RECEIVE_OUT_PORT=9091;
    //该服务器的端口号
    PrintWriter m_printWriter;
    ServerSocket m_rOutServer=null;

        //ServerSocket的实例
    Socket socketOut=null;


    final int RECEIVE_IN_PORT=9090;
        ServerSocket m_rInServer=null;
        //用户连接的通信套接字
        Socket socketIn=null;
        BufferedReader input;
        //输入流
        String m_sReadIn="";

        public static boolean Isnotread=true;


    //receiveServer的构造器
    public MyServer()
    {
        try
        {

            m_rOutServer=new ServerSocket(RECEIVE_OUT_PORT);
             //初始化ServerSocket
            //showMessage("Welcome to the server!");
            System.out.println("Welcome to the server!");
            System.out.println(new Date());
            System.out.println("The server is ready!");

            System.out.println("Local machine's name:"+InetAddress.getLocalHost());
             //等待用户请求

            socketOut=m_rOutServer.accept();


            OutputStreamWriter writer=new OutputStreamWriter(socketOut.getOutputStream());
            m_printWriter=new PrintWriter(writer,true);
        }
        catch(IOException e1)
        {
            System.out.println(e1.getMessage());
        }

        InputStreamReader reader;
        try{
        //初始化输入、输出流
              m_rInServer=new ServerSocket(RECEIVE_IN_PORT);
              socketIn=m_rInServer.accept();
              reader=new InputStreamReader(socketIn.getInputStream());
              input=new BufferedReader(reader);
        }
        catch(IOException e)
        {
              System.out.println(e.getMessage());
        }

      }




      public boolean writeStr(String str)
      {
        if(m_printWriter==null)return false;
        try
        {
            m_printWriter.println(str);
            m_printWriter.flush();
        }
        catch(Exception e)
        {
            return false;
        }
        return true;
      }

      public void run()
      {
    //线程的执行方法
      boolean done=false;

//   while(!done )
   // {
        try
        {
            if(this.Isnotread){
              m_sReadIn = input.readLine();
            }
/*               if(!this.isAlive())
              this.resume();
            }
            else this.suspend();*/

            //接收客户机指令

        }
        catch(IOException e)
        {
            System.out.println(e.getMessage());
        }
  //  }
    try
    {    input.close();
         socketIn.close();        //关闭套接字
         m_rInServer.close();
    }
    catch(IOException e)
    {
          System.out.println(e.getMessage());
    }
    //end of run
}

public String getReadIn(){
 return m_sReadIn;
}


      public void close()
      {
        try{
            m_printWriter.close();
            socketOut.close();
            m_rOutServer.close();

        }catch(Exception e){}
      }

} //end of class