Android之Socket的基於UDP傳輸
阿新 • • 發佈:2018-12-24
一、有的手機不能直接接收UDP包,可能是手機廠商在定製Rom的時候把這個功能給關掉了。
1、可先在oncreate()方法裡面例項化一個WifiManager.MulticastLock 物件lock;具體如下:
WifiManager manager = (WifiManager) this .getSystemService(Context.WIFI_SERVICE); WifiManager.MulticastLock lock= manager.createMulticastLock("test wifi");
2、在呼叫廣播發送、接收報文之前先呼叫lock.acquire()方法;
3、用完之後及時呼叫lock.release()釋放資源,否決多次呼叫lock.acquire()方法,程式可能會崩,詳情請見
注;記得在配置檔案裡面新增如下許可權:
<uses-permission android:name="android.permission.CHANGE_WIFI_MULTICAST_STATE" />
經過這樣處理後,多數手機都能正常傳送接收到廣播報文。
二、在UDP通訊中,android端傳送UDP廣播包沒有問題。至於接收的話,有時候不能接收到包。
在UDP通訊中,android端傳送UDP廣播包沒有問題。至於接收的話,有時候不能接收到包。但是如果UDP包中指定了目標主機的地址的話,那麼android端就能正常接收。
下面上一段程式碼,大家可用這段程式碼進行測試。
1、在一個Service裡面,我們建立一個執行緒
public void onCreate() {//用於建立執行緒 WifiManager manager = (WifiManager) this .getSystemService(Context.WIFI_SERVICE); udphelper = new UdpHelper(manager); //傳遞WifiManager物件,以便在UDPHelper類裡面使用MulticastLock udphelper.addObserver(MsgReceiveService.this); tReceived = new Thread(udphelper); tReceived.start(); super.onCreate(); }
2、弄一個UDP幫助類,這個類主要用於傳送和接收資料
package com.example.com.ihome.bang.util; import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; import java.net.MulticastSocket; import java.net.SocketException; import java.net.UnknownHostException; import java.util.Observable; import com.example.com.ihome.bang.tool.SendThread; import android.net.wifi.WifiManager; import android.util.Log; /** * * UdpHelper幫助類 * * @author 陳喆榕 * */ public class UdpHelper implements Runnable { public Boolean IsThreadDisable = false;//指示監聽執行緒是否終止 private static WifiManager.MulticastLock lock; InetAddress mInetAddress; public UdpHelper(WifiManager manager) { this.lock= manager.createMulticastLock("UDPwifi"); } public void StartListen() { // UDP伺服器監聽的埠 Integer port = 8903; // 接收的位元組大小,客戶端傳送的資料不能超過這個大小 byte[] message = new byte[100]; try { // 建立Socket連線 DatagramSocket datagramSocket = new DatagramSocket(port); datagramSocket.setBroadcast(true); DatagramPacket datagramPacket = new DatagramPacket(message, message.length); try { while (!IsThreadDisable) { // 準備接收資料 Log.d("UDP Demo", "準備接受"); this.lock.acquire(); datagramSocket.receive(datagramPacket); String strMsg=new String(datagramPacket.getData()).trim(); Log.d("UDP Demo", datagramPacket.getAddress() .getHostAddress().toString() + ":" +strMsg );this.lock.release(); } } catch (IOException e) {//IOException e.printStackTrace(); } } catch (SocketException e) { e.printStackTrace(); } } public static void send(String message) { message = (message == null ? "Hello IdeasAndroid!" : message); int server_port = 8904; Log.d("UDP Demo", "UDP傳送資料:"+message); DatagramSocket s = null; try { s = new DatagramSocket(); } catch (SocketException e) { e.printStackTrace(); } InetAddress local = null; try { local = InetAddress.getByName("255.255.255.255"); } catch (UnknownHostException e) { e.printStackTrace(); } int msg_length = message.length(); byte[] messageByte = message.getBytes(); DatagramPacket p = new DatagramPacket(messageByte, msg_length, local, server_port); try { s.send(p); s.close(); } catch (IOException e) { e.printStackTrace(); } } @Override public void run() { StartListen(); } }