clientbox.java

Java ME手机应用开发大全一书的配套光盘上的源码

import java.io.DataInputStream; 
import java.io.DataOutputStream; 
import java.io.IOException; 
import java.util.Vector; 
import javax.microedition.io.Connector; 
import javax.microedition.io.StreamConnection; 
import javax.microedition.lcdui.Command; 
import javax.microedition.lcdui.CommandListener; 
import javax.microedition.lcdui.Displayable; 
import javax.microedition.lcdui.Form; 
import javax.microedition.lcdui.Gauge; 
import javax.microedition.lcdui.StringItem; 
import javax.microedition.lcdui.TextField; 
import javax.bluetooth.BluetoothStateException; 
import javax.bluetooth.DeviceClass; 
import javax.bluetooth.DiscoveryAgent; 
import javax.bluetooth.DiscoveryListener; 
import javax.bluetooth.LocalDevice; 
import javax.bluetooth.RemoteDevice; 
import javax.bluetooth.ServiceRecord; 
import javax.bluetooth.UUID; 

/** 
 * 客户端GUI 
 */ 
public class ClientBox extends Form implements Runnable, CommandListener, DiscoveryListener { 

    //字串输入框 
    TextField input = new TextField(null, "", 50, TextField.ANY); 
    StringItem result = new StringItem("结果:", ""); 
    private DiscoveryAgent discoveryAgent; 
    private UUID[] uuidSet; 

    //响应服务的UUID 
    private static final UUID ECHO_SERVER_UUID = new UUID( 
            "F0E0D0C0B0A000908070605040302010", false); 

    //设备集合 
    Vector devices = new Vector(); 
    //服务集合 
    Vector records = new Vector(); 
    //服务搜索的事务id集合 
    int[] transIDs; 
    BTMIDlet midlet; 

    public ClientBox(BTMIDlet midlet) { 
        super(""); 
        this.midlet=midlet; 
         
        this.append(result); 
         
        this.addCommand(new Command("取消",Command.CANCEL,1)); 
        this.setCommandListener(this); 
         
        new Thread(this).start(); 
    } 
     
    public void commandAction(Command arg0, Displayable arg1) { 
        if(arg0.getCommandType()==Command.CANCEL){ 
            midlet.showMainMenu(); 
        }else{ 
            //匿名内部Thread，访问远程服务。 
            Thread fetchThread=new Thread(){ 
                public void run(){ 
                    for(int i=0;i<records.size();i++){ 
                        ServiceRecord sr=(ServiceRecord)records.elementAt(i); 
                        if(accessService(sr)){ 
                            //访问到一个可用的服务即可 
                            break; 
                        } 
                    } 
                } 
            }; 
            fetchThread.start(); 
        } 
         
    } 
     
     
    private boolean  accessService(ServiceRecord sr){ 
        boolean result=false; 
         try { 
            String url = sr.getConnectionURL( 
                    ServiceRecord.NOAUTHENTICATE_NOENCRYPT, false); 
            StreamConnection    conn = (StreamConnection) Connector.open(url); 
             
            DataOutputStream dos=conn.openDataOutputStream(); 
            dos.writeUTF(input.getString()); 
            dos.close(); 
            DataInputStream dis=conn.openDataInputStream(); 
            String echo=dis.readUTF(); 
            dis.close(); 
            showInfo("反馈结果是:"+echo); 
            result=true; 
             
        } catch (IOException e) { 
             
        } 
        return result; 
    } 

    public synchronized void run() { 
        //发现设备和服务的过程中，给用户以Gauge 
        Gauge g=new Gauge(null,false,Gauge.INDEFINITE,Gauge.CONTINUOUS_RUNNING); 
        this.append(g); 
        showInfo("蓝牙初始化..."); 
        boolean isBTReady = false; 

        try { 

            LocalDevice localDevice = LocalDevice.getLocalDevice(); 
            discoveryAgent = localDevice.getDiscoveryAgent(); 

            isBTReady = true; 
        } catch (Exception e) { 
            e.printStackTrace(); 
        } 

        if (!isBTReady) { 
            showInfo("蓝牙不可用"); 
            //删除Gauge 
            this.delete(1); 
            return; 
        } 

        uuidSet = new UUID[2]; 

        //标志我们的响应服务的UUID集合 
        uuidSet[0] = new UUID(0x1101); 
        uuidSet[1] = ECHO_SERVER_UUID; 


         
        try { 
            discoveryAgent.startInquiry(DiscoveryAgent.GIAC, this); 
        } catch (BluetoothStateException e) { 

        } 

        try { 
            //阻塞,由inquiryCompleted()回调方法唤醒 
            wait(); 
        } catch (InterruptedException e1) { 
             
            e1.printStackTrace(); 
        } 
        showInfo("设备搜索完毕,共找到"+devices.size()+"个设备,开始搜索服务"); 
        transIDs = new int[devices.size()]; 
        for (int i = 0; i < devices.size(); i++) { 
            RemoteDevice rd = (RemoteDevice) devices.elementAt(i); 
            try { 
                //记录每一次服务搜索的事务id 
                transIDs[i] = discoveryAgent.searchServices(null, uuidSet, 
                        rd, this); 
            } catch (BluetoothStateException e) { 
                continue; 
            } 

        } 
         
        try { 
            //阻塞,由serviceSearchCompleted()回调方法在所有设备都搜索完的情况下唤醒 
            wait(); 
        } catch (InterruptedException e1) { 
            e1.printStackTrace(); 
        } 
         
        showInfo("服务搜索完毕,共找到"+records.size()+"个服务,准备发送请求"); 
        if(records.size()>0){ 
            this.append(input); 
            this.addCommand(new Command("发送",Command.OK,0)); 
        } 
         
        //删除Gauge 
        this.delete(1); 
         
    }      
    private void showInfo(String s){ 
        StringBuffer sb=new StringBuffer(result.getText()); 
        if(sb.length()>0){ 
            sb.append("\n"); 
        } 
        sb.append(s); 
        result.setText(sb.toString()); 

    } 
     
    /** 
     * 回调方法 
     */ 

    public void deviceDiscovered(RemoteDevice btDevice, DeviceClass cod) { 

        if (devices.indexOf(btDevice) == -1) { 
            devices.addElement(btDevice); 
        } 
    } 

    /** 
     * 回调方法，唤醒初始化线程 
     */ 
    public void inquiryCompleted(int discType) { 

        synchronized (this) { 
            notify(); 
        } 
    } 
    /** 
     * 回调方法 
     */ 
    public void servicesDiscovered(int transID, ServiceRecord[] servRecord) { 
        for (int i = 0; i < servRecord.length; i++) { 
            records.addElement(servRecord[i]); 
        } 
    } 
     
    /** 
     * 回调方法，唤醒初始化线程 
     */ 

    public void serviceSearchCompleted(int transID, int respCode) { 
         
        for (int i = 0; i < transIDs.length; i++) { 
            if (transIDs[i] == transID) { 
                transIDs[i] = -1; 
                break; 
            } 
        } 
         
        //如果所有的设备都已经搜索服务完毕，则唤醒初始化线程。 

        boolean finished = true; 
        for (int i = 0; i < transIDs.length; i++) { 
            if (transIDs[i] != -1) { 
                finished = false; 
                break; 
            } 
        } 

        if (finished) { 
            synchronized (this) { 
                notify(); 
            } 
        } 

    } 

}