server.java~62~

一个发送短信和接受短信的代码！忽忽忽忽户忽忽忽忽！

package fourconnect;

/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2006</p>
 * <p>Company: </p>
 * @author not attributable
 * @version 1.0
 */
import java.io.*;
import javax.microedition.io.*;
import java.util.*;
public class Server  extends Thread{
  Thread thread;
  InputStream in;
  OutputStream out;
  ServerSocketConnection ssc;//基于服务器的套界字连接
  SocketConnection sc;
  public static Sender send1;
  public String sentstring;
  public int r=0;
 // public int status[]=new int[70];
  public Server() {
//    try{
//      ssc=(ServerSocketConnection)Connector.open("socket://:4000");
//      sc=(SocketConnection)ssc.acceptAndOpen();
//      in=sc.openDataInputStream();
//      out=sc.openDataOutputStream();
//      send1=new Sender(out);
//      //start();
//    }catch(Exception e){e.printStackTrace();System.out.println("init socket error!");}
  }
public void start(){
  thread=new Thread(this);
  thread.start();
  }
public void run(){
    try{
      ssc=(ServerSocketConnection)Connector.open("socket://:4000");
      sc=(SocketConnection)ssc.acceptAndOpen();
      in=sc.openDataInputStream();
      out=sc.openDataOutputStream();
      send1=new Sender(out);
      //start();
    }catch(Exception e){e.printStackTrace();System.out.println("init socket error!");}
 try{
  while(gamecanvas.isgame){
  StringBuffer strbuf=new StringBuffer();
  int c;
  while((c=in.read())!='\n'&&(c!=-1)){
  strbuf.append((char)c);
  strbuf.toString();
  }
  //if(c==1) break;
  Thread.sleep(40);
  /********************************/
  int status[]=new int[70];
   try{
     if(strbuf.toString().startsWith("A")) {
     sentstring = strbuf.toString().substring(1, strbuf.toString().length());
 }

    for(int i=0;i<42;i++)
       {status[i]=Integer.parseInt(sentstring.substring(i,i+1));}
    }catch(Exception e){e.printStackTrace();System.out.println("mmmmmmmmmm");}

  try{for (int i = 0; i < 6; i++)
      for (int j = 0; j < 7; j++) {
        gamecanvas.map[i][j] = status[r];
        // System.out.println(status[r+1]+" server");
        r++;
      }
  }catch(Exception e){e.printStackTrace();System.out.println("xxxxxxxxxxxx");}
  /**************************************/

  }
 }catch(Exception e){
   e.printStackTrace();
   System.out.println("run error!");
 }
  }
  public void stop(){
 try{
   if(in!=null){
   in.close();
   }if(out!=null){
  out.close();
   }if(ssc!=null){
   ssc.close();
   }if(sc!=null){
   sc.close();
   }
  }catch(Exception e){e.printStackTrace();}
 }

}