myserver.java~15~

JBuilder实现的具有单机

package Server;


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

import mymatrix.NetRead;

public class MyServer
{

    final int RECEIVE_IN_PORT=9090;
    final int RECEIVE_OUT_PORT=9091;
    //该服务器的端口号
    PrintWriter m_printWriter;
    ServerSocket m_rInServer,m_rOutServer;

    NetRead m_Owner;
    //receiveServer的构造器
    public MyServer(NetRead netRead)
    {
        m_Owner=netRead;
        m_rInServer=null;
        m_rOutServer=null;
         //ServerSocket的实例
        Socket socketIn=null,socketOut=null;
         //用户请求的套接字
        Thread readThread=null;
        //用来读对方传来数据的线程
        try
        {
            m_rInServer=new ServerSocket(RECEIVE_IN_PORT);
            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("Port: "+RECEIVE_IN_PORT);
            System.out.println("Local machine's name:"+InetAddress.getLocalHost());
             //等待用户请求
            socketIn=m_rInServer.accept();
            socketOut=m_rOutServer.accept();
             //接收客户机连接请求
            showMessage("Has been conected");
            readThread=new ReadThread(socketIn,this);
            //生成serverThread的实例
            readThread.start();
            //启动serverThread线程

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

/*      public static void main(String args[])
      {

      }
      }*/
      protected void readStr(String str)
      {
            //System.out.println(str);
            m_Owner.readStr(str);
      }

      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;
      }
      private void showMessage(String str)
      {
        m_Owner.showMessage(str);
        System.out.println(str);
      }
      public void close()
      {
        try{
            m_rInServer.close();
            m_rOutServer.close();
            m_printWriter.close();
        }catch(Exception e){}
      }

} //end of class