responsemessage.java

名称 移动QQ 一个手机上的QQ

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

public class ResponseMessage extends Thread
{
   private String ServerURL="";
   
   private int data=0;
   private String myString,str,str2;
   private List myList,URLList;
   private Display display;
   
   public ResponseMessage(Display d,List tb,List tb2)
   {
     this.display=d;
     this.myList=tb;
     this.URLList=tb2;
   }
   
   public void setServerURL(String serverUrl)
   {
      this.ServerURL=serverUrl;
   }
   
   public void run()
   {
     while(true)
     {
       try
       {
         
         DataInputStream is=null;
         StreamConnection con=null;
         StreamConnection con2=null;
         DataOutputStream os=null;
         //con=(StreamConnection)Connector.open("socket://127.0.0.1:5678");
         StreamConnectionNotifier scn=(StreamConnectionNotifier)Connector.open(ServerURL);
         con=scn.acceptAndOpen();
         is=new DataInputStream(con.openInputStream());
         data=0;
         StringBuffer sb=new StringBuffer();
	 while((data=is.read())!=-1)
	 {
	    sb.append((char)data);
	 }
	 myString=sb.toString();
	 int flag=myString.indexOf('$');
	 String yy="";
	 yy = myString.substring(0,flag);
	 if(yy.equals("0"))
	 {
	   myString=myString.substring(flag+1);
	   int a = myString.indexOf('^');
	   if(a!=-1)
	   {
	       str = myString.substring(0,a);
	       str2 = myString.substring(a+1);
	   }
	 
	 //登录成功返回消息
	
	 con2=(StreamConnection)Connector.open(str2);
         os=new DataOutputStream(con2.openOutputStream());
	 String SendMsg="0$OK";
	 
	 for(int i=0;i<URLList.size();i++)
	 {
	    if(SendMsg.equals("0$OK"))
	    {
	      SendMsg=SendMsg+"~"+URLList.getString(i);
	    }
	    else
	    {
	      SendMsg=SendMsg+"*"+URLList.getString(i);
	    }
	 }
	 if(SendMsg.equals("0$OK"))
	 {
	   SendMsg="0$OK~";
	 }
	 
	 byte data[]=SendMsg.getBytes();
         os.write(data,0,data.length);
	 os.flush();
	 //发送结束
	 int oo=0;
	 String msgstr="";
	 for(int i=0;i<URLList.size();i++)
	 {
	   
	   oo=URLList.getString(i).indexOf('^');
	   if(oo!=-1)
	   {
	     str2 = URLList.getString(i).substring(oo+1);
	     con2=(StreamConnection)Connector.open(str2);
             os=new DataOutputStream(con2.openOutputStream());
             msgstr="0$OK~"+myString;
             byte data1[]=msgstr.getBytes();
             os.write(data1,0,data1.length);
	     os.flush();
	   }
	 }
	 
	 myList.append(str,loadImage("/man.png"));
	 URLList.append(myString,null);
	 int kk=myList.size();
	 myList.setTitle("在线人数:"+kk+"人");
	 display.setCurrent(myList);
	}
	
	else if(yy.equals("1"))
	{
	  myString=myString.substring(flag+1);
	  int a = myString.indexOf('#');
	  String sendmsg="";
	  String sendURL="";
	  String thisName="";
	  String msgstr="";
	  if(a!=-1)
	  {
	     sendmsg = myString.substring(0,a);
	     str2 = myString.substring(a+1);
	  }
	  int aa=str2.indexOf('!');
	  thisName=str2.substring(0,aa);
	  sendURL=str2.substring(aa+1);
	  con2=(StreamConnection)Connector.open(sendURL);
          os=new DataOutputStream(con2.openOutputStream());
          msgstr="1$"+thisName+"^"+sendmsg;
          System.out.println(msgstr);
          byte data2[]=msgstr.getBytes();
          os.write(data2,0,data2.length);
	  os.flush();
	}
	else if(yy.equals("2"))
	{
	  myString=myString.substring(flag+1);
	 
	  String strmy="";
	  for(int i=0;i<myList.size();i++)
	  {
	   strmy=myList.getString(i);
	   
	   if(strmy.equals(myString))
	   {
	     myList.delete(i);
	   }
	  } 
	  for(int i=0;i<URLList.size();i++)
	  {
	   strmy=URLList.getString(i);
	   int jj=strmy.indexOf("^");
	   strmy=str2.substring(0,jj);
	   if(strmy.equals(myString))
	   {
	     URLList.delete(i);
	   }
	  }
	  int hh=0;
	  for(int i=0;i<URLList.size();i++)
	  {
	   
	   hh=URLList.getString(i).indexOf('^');
	   if(hh!=-1)
	   {
	     str2 = URLList.getString(i).substring(hh+1);
	     System.out.println(str2);
	     con2=(StreamConnection)Connector.open(str2);
             os=new DataOutputStream(con2.openOutputStream());
             strmy="2$"+myString;
             byte data1[]=strmy.getBytes();
             os.write(data1,0,data1.length);
	     os.flush();
	   }
	  }
	  int kk=myList.size();
	  myList.setTitle("在线人数:"+kk+"人");
	  display.setCurrent(myList);
	 }
       }catch(IOException e){ System.out.println("nothing"); }	
     }
   }
   
   
   public Image loadImage(String myImageURL)
   {
      Image myImage;
      try
      {
        myImage=Image.createImage(myImageURL);
      }
      catch(Exception e)
      {
        myImage=null;
      }
      return myImage;
   }
   
   
}