clientbox.java

手机蓝牙通讯

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */

package com.mir.bluetooth;

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;

//jsr082 API
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
 * @author Jagie
 *
 * TODO To change the template for this generated type comment go to
 * Window - Preferences - Java - Code Style - Code Templates
 */
public class ClientBox extends Form implements Runnable, CommandListener,
        DiscoveryListener {


    //字串输入框
    TextField input = new TextField(null, "", 50, TextField.ANY);
    //loger
    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;
    StupidBTMIDlet midlet;

    public ClientBox(StupidBTMIDlet 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);

    }

    /**
     * debug
     * @param s
     */

    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();
            }
        }

    }

}