socketserverthread.java

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

package com.wy.ch11;

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

public class SocketServerThread extends Thread{
    private TextBox tb;
    public SocketServerThread(TextBox t) {
        tb=t;
    }
    
    public void run(){
        ServerSocketConnection ssc=null;
        DataInputStream dis=null;
        DataOutputStream dos=null;
        SocketConnection sc=null;
        String url="socket://:12345";
        try{
            ssc=(ServerSocketConnection)Connector.open(url);
            while(true){
                sc=(SocketConnection)ssc.acceptAndOpen();
                dis=sc.openDataInputStream();
                dos=sc.openDataOutputStream();
                
                StringBuffer buffer=new StringBuffer("发送的信息是：");
                buffer.append(dis.readUTF());
                dos.writeUTF(buffer.toString());
                tb.setString(tb.getString()+buffer+"\n");
            }
        }catch(Exception e){
        }finally{
            try{
                if(dos!=null){
                    dos.close();
                }
                if(dis!=null){
                    dis.close();
                }
                if(sc!=null){
                    sc.close();
                }
                if(ssc!=null){
                    ssc.close();
                }
            }catch(Exception e){
            }
        }
        
    }
    
}