package WealthGod148;
import javax.microedition.io.*;
import java.io.*;
import java.io.DataOutputStream;

public class cybSocket implements Runnable
{
    static int num = 0;
    static String cmd1 = "";
    public boolean bIsSendData = false;
    private DataOutputStream dos = null;
    private DataInputStream dis = null;
    private Thread recive;
    public cybSocket(SocketConnection sc) throws IOException {
      dos = new DataOutputStream(sc.openOutputStream());
      dis = new DataInputStream(sc.openDataInputStream());
    }

    public DataOutputStream getDataOutputStream() {
      return dos;
    }

    public DataInputStream getDataInputStream() {
      return dis;
    }

    public void SocketSend() throws IOException {
      num = num + 1;
      bIsSendData = true;
      System.out.println("開始發(fā)送" + num);
      DataOutputStream dos1 = getDataOutputStream();
      cmd1 = "SendNum:" + num;
      byte bytes[] = cmd1.getBytes();
      dos1.write(bytes, 0, bytes.length);
      dos1.flush();
      System.out.println(cmd1);
      System.out.println("發(fā)送完畢" + num);
    }

    public void  SocketRecive() throws IOException{
      System.out.println("第"+ num + "次開始接收");
      DataInputStream dis1 = getDataInputStream();
      String content = "";
      int ic = 0;
      byte[] byBuff = new byte[35] ;
      System.out.println("斷點(diǎn)1");
      dis1.read(byBuff, 0, byBuff.length);
      content=new String(byBuff,0,byBuff.length);
      System.out.println("斷點(diǎn)2");
      if(content.length()!= 0)
        System.out.println("第"+ num + "次返回內(nèi)容:" + content);
      else
        System.out.println("第"+ num + "次返回內(nèi)容:" +"為空");
      System.out.println("第"+ num + "接收完畢");
      bIsSendData = false;
    }

    public void start()
    {
      recive=new Thread(this);
      recive.start();
    }

    public void run()
    {
      while(true){
        if(bIsSendData)
        {
          try {
            SocketRecive();
          }
          catch (IOException ex) {}
        }
        try {
           recive.sleep(50);
        }
        catch (InterruptedException ex1) {}

      }
    }


}