myclient.java

JBuilder实现的具有单机

package client;

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

import mymatrix.NetRead;


public class MyClient
{

    final int RECEIVE_OUT_PORT=9090;
    final int RECEIVE_IN_PORT=9091;

    PrintWriter m_printWriter;

    NetRead m_Owner;
    public MyClient(String str,NetRead netRead)
    {
        m_Owner=netRead;
        Socket socketIn=null,socketOut=null;
        Thread readThread=null;
        try
        {
            socketOut=new Socket(str,RECEIVE_OUT_PORT);
            socketIn=new Socket(str,RECEIVE_IN_PORT);//RECEIVE_IN_PORT);

            readThread=new ReadThread(socketIn,this);
            //生成serverThread的实例
            readThread.start();
            //启动serverThread线程

            OutputStreamWriter writer=new OutputStreamWriter(socketOut.getOutputStream());
            m_printWriter=new PrintWriter(writer,true);


        }
        catch(Exception e)
        {
            System.out.println("can't connect to the server");
        }
    }


      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;
      }
      /**
       * 用来显示不是对方发过来的消息
       */
      public void showMessage(String str)
      {
        m_Owner.showMessage(str);
      }
      public void close()
      {
        m_printWriter.close();
      }
}