學(xué)習(xí)了,三天的Android 藍牙開發(fā),開始是一頭霧水,看著別人講的Google官方的demo感覺很容易,所有自己也嘗試寫一個很簡單的聊天demo.可是想的很簡單,自己做起來也花了,將近一天的時間才搞定這個基本的流程設(shè)計.下面是幾點心得后面再貼代碼
10年積累的成都網(wǎng)站制作、網(wǎng)站建設(shè)、外貿(mào)網(wǎng)站建設(shè)經(jīng)驗,可以快速應(yīng)對客戶對網(wǎng)站的新想法和需求。提供各種問題對應(yīng)的解決方案。讓選擇我們的客戶得到更好、更有力的網(wǎng)絡(luò)服務(wù)。我雖然不認識你,你也不認識我。但先網(wǎng)站制作后付款的網(wǎng)站建設(shè)流程,更有張北免費網(wǎng)站建設(shè)讓你可以放心的選擇與我們合作。
1)寫一個簡單的demo也好,記得一定需要有總體的流程,才開始摳代碼
2)既然是demo畢竟就是新的知識,代碼中間的log點一定\不能少,這是你快速調(diào)試的利器
3)還是thinking in java 里面的那句話,思考什么是可變的,什么是不可變的,然后分開,這樣來實現(xiàn)代碼的封裝,感覺很不錯了.只是現(xiàn)在感覺還是很難想明白
4)開始思考以面向?qū)ο蟮牧鞒烫幚韱栴},需要怎么弄,也是封裝代碼的一種思想
藍牙聊天的基本功能:
1.實現(xiàn)一對一藍牙連接
2.實現(xiàn)一對一聊天
很簡單的功能,思路看著也很清晰,可是深入去寫,才知道,水還是深度的,java不熟的話.
此處基本的如何打開藍牙不在復(fù)述,請自行百度.
思路:
1)初始化,打開手機的藍牙,開始藍牙服務(wù)器線程,等待連接
2)配對,獲取某臺手機的藍牙address地址.
3)開啟連接線程連接手機藍牙
4)連接成功后,開啟,藍牙聊天的線程,進行聊天的通訊.
上面四步是主要思路,其中存在著幾個細節(jié)的地方,就是在開發(fā)中某些邏輯問題,線程間的安全問題,也是需要好好處理的. 讓我感受比較深的地方是,一對一聊天,相當于,首相每臺機器都可能作為服務(wù)器在進行通訊,所以一開始開啟了兩個服務(wù)監(jiān)聽,一旦有一個接入進來,這里需要弄清楚哪個是接入對象,哪個是被接入對象, 沒有作為服務(wù)端的,可以把服務(wù)端線程關(guān)閉掉。
下面貼點代碼
/** * 客戶端啟動連接線程 * 通過藍牙的mac地址獲取連接 * @author Administrator * */ private class ConnectThread extends Thread { private BluetoothDevice mDevice; private BluetoothSocket btSocket = null; public ConnectThread(String address) { // TODO Auto-generated constructor stub mDevice = mBluetoothAdapter.getRemoteDevice(address); } @Override public void run() { // TODO Auto-generated method stub connect(mDevice); } private void connect(BluetoothDevice btDev) { Method creMethod; try { creMethod = BluetoothDevice.class.getMethod("createBond"); creMethod.invoke(btDev); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } try { btSocket = btDev.createRfcommSocketToServiceRecord(MYUUID); System.out.println("========" + "start connect"); Log.d("BlueToothTestActivity", "開始連接..."); btSocket.connect(); mClientSocket = btSocket; isConnected=true; mHandler.sendEmptyMessage(SUCCESS_SERVICE_BEGIN_TALKING); // 作為客戶端 關(guān)閉 服務(wù)端 等待的鏈接 if (acceptThread != null) { acceptThread.close(); } startTalk(); } catch (IOException e) { // TODO Auto-generated catch block System.out.println("???????????????? close socket"); close(); System.out.println(e.toString()); e.printStackTrace(); } } private void close() { if (btSocket != null) { try { btSocket.close(); mHandler.sendEmptyMessage(FAILED_SERVICE_SOCRCKET); } catch (IOException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } } } }
/** * 服務(wù)端的設(shè)計 * 每個藍牙的客戶端先要開啟服務(wù)端等待接入 * @author Administrator * */ private class AcceptThread extends Thread { private final BluetoothServerSocket mmServerSocket; public AcceptThread() { // Use a temporary object that is later assigned to mmServerSocket, // because mmServerSocket is final BluetoothServerSocket tmp = null; try { // MY_UUID is the app's UUID string, also used by the client // code tmp = mBluetoothAdapter.listenUsingRfcommWithServiceRecord("Fisrt", MYUUID); } catch (IOException e) { mHandler.sendEmptyMessage(FAILED_SERVICE_SOCRCKET); } mmServerSocket = tmp; } public void run() { BluetoothSocket socket = null; // Keep listening until exception occurs or a socket is returned while (isRun) { try { socket = mmServerSocket.accept(); mHandler.sendEmptyMessage(SUCCESS_SERVICE_SOCRCKET); Log.e("TAG", "========== server start ===="); } catch (IOException e) { mHandler.sendEmptyMessage(FAILED_SERVICE_SOCRCKET); close(); } // If a connection was accepted if (socket != null) { // 服務(wù)端連接成功,啟動聊天線程,通過 同一個 socket 防止多線程賦值出現(xiàn)空值的問題 isConnected=true; mClientSocket = socket; mTalkThread = new TalkThread(); mTalkThread.start(); // Do work to manage the connection (in a separate thread) // 多線程操作小心不安全性 synchronized (BlueConnectService.this) { //close(); } } } } public void close() { isRun = false; try { mmServerSocket.close(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }
/** *設(shè)計連接成功后的聊天線程 1.建立流,打通連接 2.發(fā)送和接收數(shù)據(jù) 3.顯示數(shù)據(jù) *需要注意的是聊天的時候,需要同一個socket建立連接才能獲取對應(yīng)的輸入輸出流 */ private class TalkThread extends Thread { private final BluetoothSocket talkSocket; private final InputStream mIs; private final OutputStream mOs; private boolean isRunning = true; public TalkThread() { // TODO Auto-generated constructor stub talkSocket = mClientSocket; if (talkSocket == null) { System.out.println("================= talkThread erro "); // return; } InputStream is = null; OutputStream os = null; try { is = talkSocket.getInputStream(); os = talkSocket.getOutputStream(); } catch (IOException e) { // TODO Auto-generated catch block try { System.out.println("???????????????? close socket"); talkSocket.close(); CloseUtil.closeStream(is, os); } catch (IOException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } e.printStackTrace(); } mIs = is; mOs = os; } @Override public void run() { // TODO Auto-generated method stub super.run(); byte[] buffer = new byte[1024]; int len; while (isRunning) { try { len = mIs.read(buffer); mHandler.obtainMessage(READ_MESSAGE, len, -1, buffer).sendToTarget(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); try { isRunning = false; isConnected=false; System.out.println("???????????????? close socket"); talkSocket.close(); // 需要重啟服務(wù)器 // 啟動服務(wù)器 } catch (IOException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } CloseUtil.closeStream(mIs, mOs); } } } public void write(byte[] bytes) { try { mOs.write(bytes); mHandler.obtainMessage(WRITE_MESSAGE, bytes.length, -1, bytes).sendToTarget(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持創(chuàng)新互聯(lián)。
當前標題:Android實現(xiàn)一對一藍牙聊天APP
URL分享:http://m.rwnh.cn/article22/pgspcc.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供網(wǎng)站設(shè)計公司、微信小程序、商城網(wǎng)站、網(wǎng)站維護、標簽優(yōu)化、云服務(wù)器
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)