服务热线：13616026886

技术文档 欢迎使用技术文档，我们为你提供从新手到专业开发者的所有资源，你也可以通过它日益精进

搜索
位置:首页 > 技术文档 > JAVA > 新手入门 > 基础入门 > 查看文档

j2me蓝牙程序开发实战入门

人气：1335 2007-11-16

　　概述

　　目前，很多手机已经具备了蓝牙功能。虽然midp2.0没有包括蓝牙api,但是jcp定义了jsr82, java apis for bluetooth wireless technology (jabwt).这是一个可选api,很多支持midp2.0的手机已经实现了，比如nokia 6600, nokia 6670，nokia7610等等。对于一个开发者来说,如果目标平台支持jsr82的话，在制作联网对战类型游戏或者应用的时候，蓝牙是一个相当不错的选择。本文给出了一个最简单的蓝牙应用的j2me程序，用以帮助开发者快速的掌握jsr82。该程序分别在2台蓝牙设备上安装后，一台设备作为服务端先运行，一台设备作为客户端后运行。在服务端上我们发布了一个服务，该服务的功能是把客户端发过来的字符串转变为大写字符串。客户端起动并搜索到服务端的服务后，我们就可以从客户端的输入框里输入任意的字符串，发送到服务端去，同时观察服务端的反馈结果。

    本文并不具体讲述蓝牙的运行机制和jsr82的api结构，关于这些知识点，请参考本文的参考资料一节，这些参考资料会给你一个权威的精确的解释。

　　实例代码


　　该程序包括3个java文件。一个是midlet,另外2个为服务端gui和客户端gui。该程序已经在wtk22模拟器和nokia 6600,nokia 6670两款手机上测试通过。

　　stupidbtmidlet.java

  2. import javax.microedition.lcdui.alert;
  3. import javax.microedition.lcdui.alerttype;
  4. import javax.microedition.lcdui.command;
  5. import javax.microedition.lcdui.commandlistener;
  6. import javax.microedition.lcdui.display;
  7. import javax.microedition.lcdui.displayable;
  8. import javax.microedition.lcdui.list;
  9. import javax.microedition.midlet.midlet;
  10. import javax.microedition.midlet.midletstatechangeexception;
  12. /**
  13.  * @author jagie
  14.  * 
  15.  *  midlet
  16.  */
  17. public class stupidbtmidlet extends midlet implements commandlistener {
  18.     list list;
  20.     serverbox sb;
  22.     clientbox cb;
  24.     /*
  25.      * (non-javadoc)
  26.      * 
  27.      * @see javax.microedition.midlet.midlet#startapp()
  28.      */
  29.     protected void startapp() throws midletstatechangeexception {
  30.         list = new list("傻瓜蓝牙入门", list.implicit);
  31.         list.append("client", null);
  32.         list.append("server", null);
  33.         list.setcommandlistener(this);
  34.         display.getdisplay(this).setcurrent(list);
  36.     }
  37.     
  38.     /**
  39.      * debug方法
  40.      * @param s 要显示的字串
  41.      */
  43.     public void showstring(string s) {
  44.         displayable dp = display.getdisplay(this).getcurrent();
  45.         alert al = new alert(null, s, null, alerttype.info);
  46.         al.settimeout(2000);
  47.         display.getdisplay(this).setcurrent(al, dp);
  48.     }
  49.     
  50.     /**
  51.      * 显示主菜单
  52.      *
  53.      */
  55.     public void showmainmenu() {
  56.         display.getdisplay(this).setcurrent(list);
  57.     }
  59.     
  60.     protected void pauseapp() {
  61.         // todo auto-generated method stub
  63.     }
  65.     public void commandaction(command com, displayable disp) {
  66.         if (com == list.select_command) {
  67.             list list = (list) disp;
  68.             int index = list.getselectedindex();
  69.             if (index == 1) {
  70.                 if (sb == null) {
  71.                     sb = new serverbox(this);
  72.                 }
  73.                 sb.setstring(null);
  74.                 display.getdisplay(this).setcurrent(sb);
  75.             } else {
  76.                 //每次都生成新的客户端实例
  77.                 cb = null;
  78.                 system.gc();
  79.                 cb = new clientbox(this);
  81.                 display.getdisplay(this).setcurrent(cb);
  82.             }
  83.         }
  84.     }
  87.     protected void destroyapp(boolean arg0) throws midletstatechangeexception {
  88.         // todo auto-generated method stub
  90.     }
  92. }

　　clientbox.java

  2. import java.io.datainputstream;
  3. import java.io.dataoutputstream;
  4. import java.io.ioexception;
  6. import java.util.vector;
  8. import javax.microedition.io.connector;
  9. import javax.microedition.io.streamconnection;
  10. import javax.microedition.lcdui.command;
  11. import javax.microedition.lcdui.commandlistener;
  12. import javax.microedition.lcdui.displayable;
  13. import javax.microedition.lcdui.form;
  14. import javax.microedition.lcdui.gauge;
  15. import javax.microedition.lcdui.stringitem;
  16. import javax.microedition.lcdui.textfield;
  18. //jsr082 api
  19. import javax.bluetooth.bluetoothstateexception;
  21. import javax.bluetooth.deviceclass;
  22. import javax.bluetooth.discoveryagent;
  23. import javax.bluetooth.discoverylistener;
  24. import javax.bluetooth.localdevice;
  25. import javax.bluetooth.remotedevice;
  26. import javax.bluetooth.servicerecord;
  27. import javax.bluetooth.uuid;
  29. /**
  30.  * 客户端gui
  31.  * @author jagie
  32.  *
  33.  * todo to change the template for this generated type comment go to
  34.  * window - preferences - java - code style - code templates
  35.  */
  36. public class clientbox extends form implements runnable, commandlistener,
  37.         discoverylistener {
  39.     
  40.     //字串输入框
  41.     textfield input = new textfield(null, "", 50, textfield.any);
  42.     //loger
  43.     stringitem result = new stringitem("结果:", "");
  45.     private discoveryagent discoveryagent;
  47.     
  48.     private uuid[] uuidset;
  50.     //响应服务的uuid
  51.     private static final uuid echo_server_uuid = new uuid(
  52.             "f0e0d0c0b0a000908070605040302010", false);
  54.     //设备集合
  55.     vector devices = new vector();
  56.     //服务集合
  57.     vector records = new vector();
  58.     
  59.     //服务搜索的事务id集合
  60.     int[] transids;
  61.     stupidbtmidlet midlet;
  63.     public clientbox(stupidbtmidlet midlet) {
  64.         super("");
  65.         this.midlet=midlet;
  66.         
  67.         this.append(result);
  68.         
  69.         this.addcommand(new command("取消",command.cancel,1));
  70.         this.setcommandlistener(this);
  71.         
  72.         new thread(this).start();
  73.     }
  74.     
  75.     public void commandaction(command arg0, displayable arg1) {
  76.         if(arg0.getcommandtype()==command.cancel){
  77.             midlet.showmainmenu();
  78.         }else{
  79.             //匿名内部thread，访问远程服务。
  80.             thread fetchthread=new thread(){
  81.                 public void run(){
  82.                     for(int i=0;i<records.size();i++){
  83.                         servicerecord sr=(servicerecord)records.elementat(i);
  84.                         if(accessservice(sr)){
  85.                             //访问到一个可用的服务即可
  86.                             break;
  87.                         }
  88.                     }
  89.                 }
  90.             };
  91.             fetchthread.start();
  92.         }
  93.         
  94.     }
  95.     
  96.     
  97.     private boolean  accessservice(servicerecord sr){
  98.         boolean result=false;
  99.          try {
  100.             string url = sr.getconnectionurl(
  101.                     servicerecord.noauthenticate_noencrypt, false);
  102.             streamconnection    conn = (streamconnection) connector.open(url);
  103.             
  104.             dataoutputstream dos=conn.opendataoutputstream();
  105.             dos.writeutf(input.getstring());
  106.             dos.close();
  107.             datainputstream dis=conn.opendatainputstream();
  108.             string echo=dis.readutf();
  109.             dis.close();
  110.             showinfo("反馈结果是:"+echo);
  111.             result=true;
  112.             
  113.         } catch (ioexception e) {
  114.             
  115.         }
  116.         return result;
  117.     }
  119.     public synchronized void run() {
  120.         //发现设备和服务的过程中，给用户以gauge
  121.         gauge g=new gauge(null,false,gauge.indefinite,gauge.continuous_running);
  122.         this.append(g);
  123.         showinfo("蓝牙初始化...");
  124.         boolean isbtready = false;
  126.         try {
  128.             localdevice localdevice = localdevice.getlocaldevice();
  129.             discoveryagent = localdevice.getdiscoveryagent();
  131.             isbtready = true;
  132.         } catch (exception e) {
  133.             e.printstacktrace();
  134.         }
  136.         if (!isbtready) {
  137.             showinfo("蓝牙不可用");
  138.             //删除gauge
  139.             this.delete(1);
  140.             return;
  141.         }
  143.         uuidset = new uuid[2];
  145.         //标志我们的响应服务的uuid集合
  146.         uuidset[0] = new uuid(0x1101);
  147.         uuidset[1] = echo_server_uuid;
  150.         
  151.         try {
  152.             discoveryagent.startinquiry(discoveryagent.giac, this);
  153.         } catch (bluetoothstateexception e) {
  155.         }
  157.         try {
  158.             //阻塞,由inquirycompleted()回调方法唤醒
  159.             wait();
  160.         } catch (interruptedexception e1) {
  161.             
  162.             e1.printstacktrace();
  163.         }
  164.         showinfo("设备搜索完毕,共找到"+devices.size()+"个设备,开始搜索服务");
  165.         transids = new int[devices.size()];
  166.         for (int i = 0; i < devices.size(); i++) {
  167.             remotedevice rd = (remotedevice) devices.elementat(i);
  168.             try {
  169.                 //记录每一次服务搜索的事务id
  170.                 transids[i] = discoveryagent.searchservices(null, uuidset,
  171.                         rd, this);
  172.             } catch (bluetoothstateexception e) {
  173.                 continue;
  174.             }
  176.         }
  177.         
  178.         try {
  179.             //阻塞,由servicesearchcompleted()回调方法在所有设备都搜索完的情况下唤醒
  180.             wait();
  181.         } catch (interruptedexception e1) {
  182.             e1.printstacktrace();
  183.         }
  184.         
  185.         showinfo("服务搜索完毕,共找到"+records.size()+"个服务,准备发送请求");
  186.         if(records.size()>0){
  187.             this.append(input);
  188.             this.addcommand(new command("发送",command.ok,0));
  189.         }
  190.         
  191.         //删除gauge
  192.         this.delete(1);
  193.         
  194.     }
  195.     
  196.     /**
  197.      * debug
  198.      * @param s
  199.      */
  200.     
  201.     private void showinfo(string s){
  202.         stringbuffer sb=new stringbuffer(result.gettext());
  203.         if(sb.length()>0){
  204.             sb.append("/n");
  205.         }
  206.         sb.append(s);
  207.         result.settext(sb.tostring());
  209.     }
  210.     
  211.     /**
  212.      * 回调方法
  213.      */
  215.     public void devicediscovered(remotedevice btdevice, deviceclass cod) {
  217.         if (devices.indexof(btdevice) == -1) {
  218.             devices.addelement(btdevice);
  219.         }
  220.     }
  222.     /**
  223.      * 回调方法，唤醒初始化线程
  224.      */
  225.     public void inquirycompleted(int disctype) {
  227.         synchronized (this) {
  228.             notify();
  229.         }
  230.     }
  231.     /**
  232.      * 回调方法
  233.      */
  234.     public void servicesdiscovered(int transid, servicerecord[] servrecord) {
  235.         for (int i = 0; i < servrecord.length; i++) {
  236.             records.addelement(servrecord[i]);
  237.         }
  238.     }
  239.     
  240.     /**
  241.      * 回调方法，唤醒初始化线程
  242.      */
  244.     public void servicesearchcompleted(int transid, int respcode) {
  245.         
  246.         for (int i = 0; i < transids.length; i++) {
  247.             if (transids[i] == transid) {
  248.                 transids[i] = -1;
  249.                 break;
  250.             }
  251.         }
  252.         
  253.         //如果所有的设备都已经搜索服务完毕，则唤醒初始化线程。
  255.         boolean finished = true;
  256.         for (int i = 0; i < transids.length; i++) {
  257.             if (transids[i] != -1) {
  258.                 finished = false;
  259.                 break;
  260.             }
  261.         }
  263.         if (finished) {
  264.             synchronized (this) {
  265.                 notify();
  266.             }
  267.         }
  269.     }
  271. }

　　serverbox.java

  2. import java.io.datainputstream;
  3. import java.io.dataoutputstream;
  4. import java.io.ioexception;
  6. import java.util.vector;
  8. import javax.bluetooth.discoveryagent;
  9. import javax.bluetooth.localdevice;
  10. import javax.bluetooth.servicerecord;
  11. import javax.bluetooth.uuid;
  12. import javax.microedition.io.connector;
  13. import javax.microedition.io.streamconnection;
  14. import javax.microedition.io.streamconnectionnotifier;
  16. import javax.microedition.lcdui.command;
  17. import javax.microedition.lcdui.commandlistener;
  18. import javax.microedition.lcdui.displayable;
  20. import javax.microedition.lcdui.textbox;
  21. import javax.microedition.lcdui.textfield;
  23. /**
  24.  * 服务端gui
  25.  * @author jagie
  26.  *
  27.  * todo to change the template for this generated type comment go to
  28.  * window - preferences - java - code style - code templates
  29.  */
  30. public class serverbox extends textbox implements runnable, commandlistener {
  32.     command com_pub = new command("开启服务", command.ok, 0);
  34.     command com_cancel = new command("终止服务", command.cancel, 0);
  36.     command com_back = new command("返回", command.back, 1);
  38.     localdevice localdevice;
  40.     streamconnectionnotifier notifier;
  42.     servicerecord record;
  44.     boolean isclosed;
  46.     clientprocessor processor;
  48.     stupidbtmidlet midlet;
  49.     //响应服务的uuid
  50.     private static final uuid echo_server_uuid = new uuid(
  51.             "f0e0d0c0b0a000908070605040302010", false);
  53.     public serverbox(stupidbtmidlet midlet) {
  54.         super(null, "", 500, textfield.any);
  55.         this.midlet = midlet;
  56.         this.addcommand(com_pub);
  57.         this.addcommand(com_back);
  58.         this.setcommandlistener(this);
  59.     }
  62.     public void run() {
  63.         boolean isbtready = false;
  65.         try {
  67.             localdevice = localdevice.getlocaldevice();
  69.             if (!localdevice.setdiscoverable(discoveryagent.giac)) {
  70.                 showinfo("无法设置设备发现模式");
  71.                 return;
  72.             }
  74.             // prepare a url to create a notifier
  75.             stringbuffer url = new stringbuffer("btspp://");
  77.             // indicate this is a server
  78.             url.append("localhost").append(':');
  80.             // add the uuid to identify this service
  81.             url.append(echo_server_uuid.tostring());
  83.             // add the name for our service
  84.             url.append(";name=echo server");
  86.             // request all of the client not to be authorized
  87.             // some devices fail on authorize=true
  88.             url.append(";authorize=false");
  90.             // create notifier now
  91.             notifier = (streamconnectionnotifier) connector
  92.                     .open(url.tostring());
  94.             record = localdevice.getrecord(notifier);
  96.             // remember we've reached this point.
  97.             isbtready = true;
  98.         } catch (exception e) {
  99.             e.printstacktrace();
  100.             
  101.         }
  103.         // nothing to do if no bluetooth available
  104.         if (isbtready) {
  105.             showinfo("初始化成功，等待连接");
  106.             this.removecommand(com_pub);
  107.             this.addcommand(com_cancel);
  108.         } else {

扫描关注微信公众号

© 2005-2021 漳州市福佳网络科技有限公司 版权所有 闽ICP备09012882号-3
闽公网安备 35060202000074号
福佳空间在线客服
20944024 178966803 1946551451

扫描关注微信公众号
13616026886
JAVA空间
PHP空间
域名注册