J2ME 蓝牙搜索与连接
import java.io.IOException;import java.util.Vector;import javax.bluetooth.BluetoothStateException;import javax.bluetooth.DataElement;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;import javax.microedition.io.Connection;import javax.microedition.io.Connector;/** * 蓝牙设备搜索及服务搜索类<BR> * * * @author Administrator * @version V1.0 */public final class BlueTooth implements DiscoveryListener , Runnable{ /** * 准备 */ public static final int STATUS_READY = 0x01; /** * 设备搜索中 */ public static final int STATUS_DEV_SEARCHING = 0x02; /** * 设备搜索完成 */ public static final int STATUS_DEV_SEARCH_FINISH = 0x03; /** * 设备搜索失败 */ public static final int STATUS_DEV_SEARCH_ERROR = 0x04; /** * 服务搜索中 */ public static final int STATUS_SER_SEARCHING = 0x10; /** * 服务搜索完成 */ public static final int STATUS_SER_SEARCH_FINISH = 0x11; /** * 服务搜索失败 */ public static final int STATUS_SER_SEARCH_ERROR = 0x12; /** * 创建与服务的连接中 */ public static final int STATUS_CONNECTING = 0x20; /** * 创建服务连接成功 */ public static final int STATUS_CONNECT_OK = 0x21; /** * 创建服务连接失败 */ public static final int STATUS_CONNECT_FAIL = 0x22; /** * 单实例 */ private static BlueTooth instance = new BlueTooth(); /** * 本地设备 */ protected LocalDevice localDevice; /** * 设备搜索代理 */ protected DiscoveryAgent discoveryAgent; /** * 搜索到的设备列表 */ protected Vector remoteDeviceVector = new Vector(); /** * 搜索到的服务信息列表 */ protected Vector serviceInfoVector = new Vector(); /** * 搜索到的服务列表 */ protected Vector serviceRecordVector = new Vector(); /** * */ // protected int connectType = 0; /** * 状态 */ protected int status = 0; /** * 是否支持蓝牙 */ protected boolean supportJSR82 = false; /** * 对象锁，控制设备搜索和服务搜索 */ private Object bluelock = new Object(); /** * 过滤器 */ private Filter filter; /** * 预设设备 */ private String expectDevice; /** * 构造子 */ private BlueTooth() { try { Class.forName("javax.bluetooth.LocalDevice"); supportJSR82 = true; } catch (Exception ex) { supportJSR82 = false; } try { // 获得本地设备 localDevice = LocalDevice.getLocalDevice(); // 获得本地设备代理 discoveryAgent = localDevice.getDiscoveryAgent(); } catch (Exception e) { supportJSR82 = false; } } /** * 获取单实例 * * @return 静态单实例 */ public static BlueTooth getInstance() { return instance; } /** * 搜索蓝牙设备 * * @return 搜索到的蓝牙设备 */ public Vector findDevices() { remoteDeviceVector.removeAllElements(); try { // 启动搜索代理发现设备并与DiscoveryListener注册回调 discoveryAgent.startInquiry(DiscoveryAgent.GIAC, this); // 设备搜索状态 setStatus(STATUS_DEV_SEARCHING); // 设备搜索过程是异步的，这里需要同步搜索过程 // 设备搜索完毕会通知主线程继续运行 synchronized (bluelock) { // 加上while,break纯粹是为了规避findbugs检查 while (status >= STATUS_READY && status < STATUS_DEV_SEARCH_FINISH) { try { bluelock.wait(); // break; } catch (Exception e) { break; } } } } catch (BluetoothStateException e) { setStatus(STATUS_DEV_SEARCH_ERROR); } return remoteDeviceVector; } /** * 获取手机匹配装置列表中的蓝牙设备集合 * * @return 搜索到的蓝牙设备 */ public Vector findDeviceInCache() { Vector vector = new Vector(); RemoteDevice[] rds = discoveryAgent.retrieveDevices(DiscoveryAgent.CACHED); if (rds != null) { for (int i = 0; i < rds.length; i++) { vector.addElement(rds[i]); } } rds = discoveryAgent.retrieveDevices(DiscoveryAgent.PREKNOWN); if (rds != null) { for (int i = 0; i < rds.length; i++) { vector.addElement(rds[i]); } } return vector; } /** * 取消正在执行的设备搜索 */ public void cancelFindDevices() { if (status == STATUS_DEV_SEARCHING) { discoveryAgent.cancelInquiry(this); } } /** * 蓝牙设备发现时的回调方法<BR> * 每发现一个蓝牙装置，此方法将被调用一次。 * * @param btDevice 搜索到的蓝牙装置 * @param cod 服务类，远程蓝牙装置的主设备类或附设备类 * @see javax.bluetooth.DiscoveryListener#deviceDiscovered(javax.bluetooth.RemoteDevice, * javax.bluetooth.DeviceClass) */ public void deviceDiscovered(RemoteDevice btDevice, DeviceClass cod) { if (filter != null && !filter.match(btDevice)) { return; } else { remoteDeviceVector.addElement(btDevice); } if (expectDevice != null && expectDevice.equals(btDevice.getBluetoothAddress())) { discoveryAgent.cancelInquiry(this); } } /** * 设备搜索结束时的回调方法<BR> * * * @param discType 搜索请求结束类型; 为INQUIRY_COMPLETED, INQUIRY_TERMINATED, 或INQUIRY_ERROR * @see javax.bluetooth.DiscoveryListener#inquiryCompleted(int) */ public void inquiryCompleted(int discType) { if (discType == INQUIRY_COMPLETED) { setStatus(STATUS_DEV_SEARCH_FINISH); } else if (discType == INQUIRY_ERROR) { setStatus(STATUS_DEV_SEARCH_ERROR); } // 蓝牙搜索执行完毕，通知主线程继续 synchronized (bluelock) { bluelock.notifyAll(); } } /** * 搜索蓝牙设备提供的服务 * * @param device 远程蓝牙设备 * @param uuids 搜索服务UUID数组 * @return 搜索到的服务集合 */ public Vector findServices(RemoteDevice device, UUID[] uuids) { serviceInfoVector.removeAllElements(); serviceRecordVector.removeAllElements(); try { discoveryAgent.searchServices(new int[] {0x100 }, uuids, device, this); setStatus(STATUS_SER_SEARCHING); } catch (BluetoothStateException e) { setStatus(STATUS_SER_SEARCH_ERROR); } synchronized (bluelock) { // 加上while,break纯粹是为了规避findbugs检查 while (status > STATUS_DEV_SEARCHING && status <= STATUS_SER_SEARCHING) { try { bluelock.wait(); // break; } catch (InterruptedException e) { break; } } } return serviceRecordVector; } /** * 搜索服务时找到服务的回调方法<BR> * [功能详细描述] * * @param transID 服务搜索事务ID * @param servRecord 搜索到的服务记录数组 * @see javax.bluetooth.DiscoveryListener#servicesDiscovered(int, javax.bluetooth.ServiceRecord[]) */ public void servicesDiscovered(int transID, ServiceRecord[] servRecord) { if (servRecord != null) { for (int i = 0; i < servRecord.length; i++) { DataElement serviceNameElement = servRecord[i].getAttributeValue(0x0100); String serviceName = (serviceNameElement.getValue().toString()).trim(); ServiceInfo info = new ServiceInfo(); info.name = serviceName; serviceInfoVector.addElement(info); serviceRecordVector.addElement(servRecord[i]); } } } /** * 搜索服务结束回调方法<BR> * 结束包含正常结束，手动终止或错误 * * @param transID 搜索事务ID * @param respCode 搜索响应码 * @see javax.bluetooth.DiscoveryListener#serviceSearchCompleted(int, int) */ public void serviceSearchCompleted(int transID, int respCode) { switch (respCode) { case DiscoveryListener.SERVICE_SEARCH_COMPLETED: case DiscoveryListener.SERVICE_SEARCH_DEVICE_NOT_REACHABLE: case DiscoveryListener.SERVICE_SEARCH_NO_RECORDS: case DiscoveryListener.SERVICE_SEARCH_TERMINATED: { setStatus(STATUS_SER_SEARCH_FINISH); break; } case DiscoveryListener.SERVICE_SEARCH_ERROR: { setStatus(STATUS_SER_SEARCH_ERROR); break; } default: { setStatus(STATUS_SER_SEARCH_FINISH); break; } } synchronized (bluelock) { bluelock.notifyAll(); } } /** * 线程run方法<BR> * 搜索设备 * * @see java.lang.Runnable#run() */ public void run() { if (supportJSR82) { findDevices(); } } /** * 根据服务URL创建连接 * * @param url 从ServiceRecord中获取的服务URL * @return 创建的连接 * @exception IOException 当创建连接失败时,抛出IO异常 */ public Connection getConnection(String url) throws IOException { Connection conn = null; try { setStatus(STATUS_CONNECTING); conn = Connector.open(url); setStatus(STATUS_CONNECT_OK); // RemoteDevice rd = RemoteDevice.getRemoteDevice(conn); } catch (IOException e) { setStatus(STATUS_CONNECT_FAIL); throw e; } return conn; } /** * 根据服务记录创建连接 * * @param service 搜索记录 * @return 创建的连接 * @exception IOException 当创建连接失败时,抛出IO异常 */ public Connection getConnection(ServiceRecord service) throws IOException { String url = service.getConnectionURL(ServiceRecord.NOAUTHENTICATE_NOENCRYPT, false); return getConnection(url); } // -----------------> getter & setter /** * 获取搜索到的蓝牙设备列表<br /> * 如果要获取最终的设备列表，需要在status=STATUS_DEV_SEARCH_FINISH时，再调用此方法 * * @return 搜索到的蓝牙设备列表 */ public Vector getRemoteDeviceVector() { return remoteDeviceVector; } /** * 获取搜索到的服务列表 * * @return 搜索到的ServiceRecord列表 */ public Vector getServiceRecordVector() { return serviceRecordVector; } /** * 获取搜索到的服务信息列表 * * @return 搜索到的ServiceRecord信息列表 */ public Vector getServiceInfoVector() { return serviceInfoVector; } /** * 获取当前状态 * * @return 状态 */ public int getStatus() { return status; } /** * 设置状态 * * @param status 要设置的状态 */ public void setStatus(int status) { this.status = status; } /** * 判断是否支持jsr82规范 * * @return 是否支持蓝牙 */ public boolean isSupportJSR82() { return supportJSR82; } /** * 设置搜索过滤器 * * @param filter 搜索设备时的过滤器 */ public void setFilter(Filter filter) { this.filter = filter; } /** * 获取设备过滤器 * * @return 设备过滤器 */ public Filter getFilter() { return filter; } /** * 设备搜索过滤器<BR> * 如果符合匹配条件,则将搜索到的设备加入搜索结果集合当中 * * @author Adminstrator * @version V1.0 */ public static abstract class Filter { /** * 判断设备是否符合过滤规则 * * @param device 搜索到的设备 * @return 是否符合过滤规则 */ public abstract boolean match(RemoteDevice device); }}