myserver.java~14~

JBuilder实现的具有单机

package Server;


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


public class MyServer
{

public static boolean Isnotread=true;
final int RECEIVE_IN_PORT=9090;
final int RECEIVE_OUT_PORT=9091;
 //该服务器的端口号
 PrintWriter m_printWriter;
 ServerSocket m_rInServer=null,m_rOutServer=null;
 Socket socketIn=null,socketOut=null;
 ReadThread readThread=null;
 //receiveServer的构造器
 public MyServer()
 {

      //用户请求的套接字

     //用来读对方传来数据的线程
     try
     {
         m_rInServer=new ServerSocket(RECEIVE_IN_PORT);
         m_rOutServer=new ServerSocket(RECEIVE_OUT_PORT);
          //初始化ServerSocket

         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();
          //接收客户机连接请求

         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 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 String getReadIn(){
     return readThread.getReadIn();
   }


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

        }catch(Exception e){}
      }


} //end of class*/