socketthread.java

基于J2me的手机软件演示例子

package com.wy.ch11;

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

public class SocketThread extends Thread{
    private String context;
    private StringItem si;
    public SocketThread(String c,StringItem s) {
        context=c;
        si=s;
    }
    
    public void run(){
        String url="socket://127.0.0.1:12345";
        SocketConnection sc=null;
        DataInputStream dis=null;
        DataOutputStream dos=null;
        StringBuffer buffer=new StringBuffer();
        try{
            sc=(SocketConnection)Connector.open(url);
            dis=sc.openDataInputStream();
            dos=sc.openDataOutputStream();
            dos.writeUTF(context);
            dos.flush();
            buffer.append(dis.readUTF());
        }catch(Exception e){
        } finally{
            si.setText(si.getText()+buffer+"\n");
            try{
                if(dos!=null){
                    dos.close();
                }
                if(dis!=null){
                    dis.close();
                }
                if(sc!=null){
                    sc.close();
                }
            }catch(Exception e){
            }
        }
    }
    
}