// *******************************************************
//
// FILENAME:    	betmain.java
// PROJECT:		BetSprite
// DESCRIPTION:		賭神網(wǎng)絡(luò)版
//
//
// *******************************************************

import java.io.*;
import javax.microedition.io.*;
import javax.microedition.lcdui.*;
import javax.microedition.midlet.*;

public class SocketThread extends Thread {

  //有些函數(shù)必需要寫(xiě)在外邊，靠，什么爛東西，封裝很差
  InputStream is = null;
  OutputStream os = null;
  StreamConnection socket = null;
  String GMessage;

  boolean B_Socketthread = true; // socket 線程開(kāi)關(guān) true 為啟動(dòng)
  boolean Intranet = true;// 局域網(wǎng)和廣域網(wǎng)測(cè)試開(kāi)關(guān) TRUE 為局域網(wǎng)
  boolean Debug = false;//debug 開(kāi)關(guān) true is debug state
  //////////////////////////////////////////////////////////////////////
  //
  //      //這里實(shí)例化
  //
  //////////////////////////////////////////////////////////////////////

  public SocketThread()
  {
       super(); 
       if (Intranet)
         Debug = true;
  }
  public void run()
  {

    if(Debug == true)
      System.out.print("Inside SocketThread Constructor...\n");
  }

  /////////////////////////////////////////////////////////////
  // accept
  //
  //
  /////////////////////////////////////////////////////////////
  public void accept()
  {

    String name = "NULL";
    try{

      if(Intranet == true)
      {
        // 本地測(cè)試IP
        name =  "socket://192.168.0.58:54757";
      }
      else
      {
        name =  "socket://202.96.138.83:54757";
      }

      socket = (StreamConnection)Connector.open(name, Connector.READ_WRITE);

      if(Debug == true)
        System.out.print("getmessage() working:accept\n");

      GMessage=getmessage();
    }
    catch(Exception ex)
    {
      if(Debug == true)
        System.out.print("getmessage() failing:accept\n");
    }
    if(Debug == true)
      System.out.print("accept() is open");
  }

  /////////////////////////////////////////////////////////////
  // 獲得消息
  //
  //
  /////////////////////////////////////////////////////////////

  public String getmessage()
  {
    String s="NULL";
    int i=0;
    if(Debug == true)
      System.out.print("getmessage() start\n");

    try {

      //socket =(StreamConnection)Connector.open(,Connector.READ, true);
      is = socket.openInputStream();
      if(Debug == true)
        System.out.print("socket.open sending 1\n");
    }
    catch (Exception e) {}

    try {
      int b;
      StringBuffer sb = new StringBuffer();
      if(Debug == true)
        System.out.print("socket.open 1\n");
      while ( (b = is.read()) != 97) // 42 是“*”97 "a"
      {
        sb.append((char)b);
        i++;
        if(Debug == true)
          System.out.print("recive Message.\n");
      }
      //socket.close();
      if(Debug == true)
        System.out.print("socket.close() working,get \n");
      if(i!=0)
        s = sb.toString();
      if(Debug == true)
        System.out.print("sb.toString() working"+s+"\n");

      //dt.setText(sb.toString());
      //display.setCurrent(outputForm);
    }
    catch (Exception e)
    {
      if(Debug == true)
        System.out.print("sb.toString() failed\n");
    }
    return s;
  }


  /////////////////////////////////////////////////////////////
  // 發(fā)送消息
  //
  //
  /////////////////////////////////////////////////////////////
  public void sendmessage(String request)
  {
    try
    {
      //send the message to the server
      os = socket.openOutputStream();
      os.write(request.getBytes());
      //os.close();
      socket.close();
    }
    catch(IOException ex)
    {
      return;
    }

    finally
    {
      try
      {
        if(socket != null)
        {
          socket.close();
          socket = null;
        }
      }
      catch (IOException ex1)
          {}
    }
  }
}