C# 在PC上的通過(guò)藍(lán)牙(Bluetooth)發(fā)送數(shù)據(jù)到手機(jī)，你會(huì)嗎？

作者：conan 2021-06-02 00:15:41

在PC端用.NET開(kāi)發(fā)一個(gè)藍(lán)牙下載的程序。實(shí)現(xiàn)在PC上查找周?chē)乃{(lán)牙設(shè)備(主要是手機(jī))，并將PC上的文件通過(guò)藍(lán)牙傳輸?shù)绞謾C(jī)上。

[[403076]]

本文轉(zhuǎn)載自微信公眾號(hào)「后端Q」，作者conan。轉(zhuǎn)載本文請(qǐng)聯(lián)系后端Q公眾號(hào)。

概述

在PC端用.NET開(kāi)發(fā)一個(gè)藍(lán)牙下載的程序。實(shí)現(xiàn)在PC上查找周?chē)乃{(lán)牙設(shè)備(主要是手機(jī))，并將PC上的文件通過(guò)藍(lán)牙傳輸?shù)绞謾C(jī)上。目前我采用的是OpenNETCF.Net.Bluetooth，能夠正常發(fā)現(xiàn)周?chē)乃{(lán)牙設(shè)備，手機(jī)也能夠正常進(jìn)行藍(lán)牙連接并接收文件。

代碼實(shí)現(xiàn)

1、查找周?chē){(lán)牙設(shè)備

BluetoothClient bc = new BluetoothClient(); 
        BluetoothDeviceInfo[] bdi; 
        bdi = bc.DiscoverDevices(10);//查找周?chē)疃?0個(gè)藍(lán)牙設(shè)備 
        if (bdi.Length == 0) 
        { 
            this.ShowErrMsg("請(qǐng)確認(rèn)您的藍(lán)牙已開(kāi)啟！"); 
            return; 
        }

2、打開(kāi)數(shù)據(jù)流

#region OBEXOpenStream 
    public bool OBEXOpenStream(string BTMAC) 
    { 
 
        // serial port UUID 
        Guid spguid = OpenNETCF.Net.Bluetooth.BluetoothService.ObexObjectPush; 
        OpenNETCF.Net.BluetoothAddress btaddress = OpenNETCF.Net.BluetoothAddress.Parse(BTMAC); 
        client = new OpenNETCF.Net.Sockets.BluetoothClient(); 
 
        // define endpoint 
        OpenNETCF.Net.BluetoothEndPoint endpoint = new OpenNETCF.Net.BluetoothEndPoint(btaddress, spguid); 
 
        try 
        { 
            //open socket 
            client.Connect(endpoint); 
        } 
        catch 
        { 
            //unable to connect (server not listening on spguid) 
            return false; 
        } 
 
        //connect socket 
        stream = client.GetStream(); 
        return true; 
    } 
    #endregion

3、配對(duì)連接

private bool OBEXConnect() 
    { 
        //send client request 
        byte[] ConnectPacket = new byte[7]; 
 
        ConnectPacket[0] = 0x80;      // Connect 
        ConnectPacket[1] = 0x00;      // Packetlength Hi Byte 
        ConnectPacket[2] = 0x07;      // Packetlength Lo Byte 
        ConnectPacket[3] = 0x10;      // Obex v1 
        ConnectPacket[4] = 0x00;      // no flags 
        ConnectPacket[5] = 0x20;      // 8k max packet size Hi Byte 
        ConnectPacket[6] = 0x00;      // 8k max packet size Lo Byte 
 
        stream.Write(ConnectPacket, 0, ConnectPacket.Length); 
 
        //listen for server response 
        byte[] ReceiveBufferA = new byte[3]; 
        stream.Read(ReceiveBufferA, 0, 3); 
 
        if (ReceiveBufferA[0] == 160) // 0xa0 
        { 
 
            //success, decode rest of packet 
            int plength = (0xff * ReceiveBufferA[1]) + ReceiveBufferA[2]; //length of packet is... 
 
            //listen for rest of packet 
            byte[] ReceiveBufferB = new byte[plength - 3]; 
            stream.Read(ReceiveBufferB, 0, plength - 3); 
 
            int obver = ReceiveBufferB[0]; //server obex version (16 = v1.0) 
            int cflags = ReceiveBufferB[1]; //connect flags 
            int maxpack = (0xff * ReceiveBufferB[2]) + ReceiveBufferB[3]; //max packet size 
 
            return true; 
        } 
        else 
        { 
            return false; 
        } 
    }

4、發(fā)送文本內(nèi)容

//send client request, start put 
                        string tName = "BRT優(yōu)惠卷.txt"; 
                        string tType = ""; 
                        string tFileContent = "優(yōu)惠卷內(nèi)容:" + this.txtContent.Text.Trim(); 
 
                        int result = OBEXRequest("PUT", tName, tType, tFileContent); 
                        if (result == 160) 
                        { 
                            SendSuccess = true; 
                        }

完整代碼

using System; 
using System.Data; 
using System.Configuration; 
using System.Web; 
using System.Web.Security; 
using System.Web.UI; 
using System.Web.UI.WebControls; 
using System.Web.UI.WebControls.WebParts; 
using System.Web.UI.HtmlControls; 
using System.Net.Sockets; 
using OpenNETCF; 
using OpenNETCF.Net; 
using OpenNETCF.Net.Bluetooth; 
using OpenNETCF.Net.Sockets; 
 
public partial class _Default : System.Web.UI.Page  
{ 
    //Stream stream; 
    NetworkStream stream; 
    OpenNETCF.Net.Sockets.BluetoothClient client; 
    protected void Page_Load(object sender, EventArgs e) 
{ 
 
    } 
 
    #region ShowErrMsg 
    private void ShowErrMsg(string err) 
{ 
        string str; 
        str = "<script language='javascript'>"; 
        str += " alert('" + err + "')"; 
        str += "</script>"; 
        this.RegisterStartupScript("", str); 
    } 
    #endregion 
    protected void btnSend_Click(object sender, EventArgs e) 
{ 
        if (this.txtContent.Text.Trim() == string.Empty) 
        { 
            this.ShowErrMsg("請(qǐng)輸入發(fā)送內(nèi)容！"); 
            return; 
        } 
        BluetoothClient bc = new BluetoothClient(); 
        BluetoothDeviceInfo[] bdi; 
        bdi = bc.DiscoverDevices(10);//查找周?chē)疃?0個(gè)藍(lán)牙設(shè)備 
        if (bdi.Length == 0) 
        { 
            this.ShowErrMsg("請(qǐng)確認(rèn)您的藍(lán)牙已開(kāi)啟！"); 
            return; 
        } 
        bool SendSuccess = false; 
        try 
        { 
            foreach (BluetoothDeviceInfo bd in bdi) 
            { 
                if (OBEXOpenStream(bd.DeviceID.ToString())) 
                { 
 
                    if (OBEXConnect()) 
                    { 
                        //send client request, start put 
                        string tName = "BRT優(yōu)惠卷.txt"; 
                        string tType = ""; 
                        string tFileContent = "優(yōu)惠卷內(nèi)容:" + this.txtContent.Text.Trim(); 
 
                        int result = OBEXRequest("PUT", tName, tType, tFileContent); 
                        if (result == 160) 
                        { 
                            SendSuccess = true; 
                        } 
                    } 
                    OBEXCloseStream(); 
                } 
                else 
                { 
                    this.ShowErrMsg("連接失敗！" + bd.DeviceName.ToString()); 
                } 
 
            } 
            if (SendSuccess) 
            { 
                this.ShowErrMsg("發(fā)送成功，謝謝使用！"); 
            } 
        } 
        finally 
        { 
            OBEXCloseStream(); 
        } 
    } 
 
 
    #region OBEXOpenStream 
    public bool OBEXOpenStream(string BTMAC) 
{ 
 
        // serial port UUID 
        Guid spguid = OpenNETCF.Net.Bluetooth.BluetoothService.ObexObjectPush; 
        OpenNETCF.Net.BluetoothAddress btaddress = OpenNETCF.Net.BluetoothAddress.Parse(BTMAC); 
        client = new OpenNETCF.Net.Sockets.BluetoothClient(); 
 
        // define endpoint 
        OpenNETCF.Net.BluetoothEndPoint endpoint = new OpenNETCF.Net.BluetoothEndPoint(btaddress, spguid); 
 
        try 
        { 
            //open socket 
            client.Connect(endpoint); 
        } 
        catch 
        { 
            //unable to connect (server not listening on spguid) 
            return false; 
        } 
 
        //connect socket 
        stream = client.GetStream(); 
        return true; 
    } 
    #endregion 
 
    #region OBEXCloseStream 
    private void OBEXCloseStream() 
{ 
        if (stream != null) 
        { 
            stream.Close(); 
        } 
        if (client != null) 
        { 
            client.Close(); 
        } 
    } 
    #endregion 
 
    #region  OBEXConnect 
    private bool OBEXConnect() 
{ 
        //send client request 
        byte[] ConnectPacket = new byte[7]; 
 
        ConnectPacket[0] = 0x80;      // Connect 
        ConnectPacket[1] = 0x00;      // Packetlength Hi Byte 
        ConnectPacket[2] = 0x07;      // Packetlength Lo Byte 
        ConnectPacket[3] = 0x10;      // Obex v1 
        ConnectPacket[4] = 0x00;      // no flags 
        ConnectPacket[5] = 0x20;      // 8k max packet size Hi Byte 
        ConnectPacket[6] = 0x00;      // 8k max packet size Lo Byte 
 
        stream.Write(ConnectPacket, 0, ConnectPacket.Length); 
 
        //listen for server response 
        byte[] ReceiveBufferA = new byte[3]; 
        stream.Read(ReceiveBufferA, 0, 3); 
 
        if (ReceiveBufferA[0] == 160) // 0xa0 
        { 
 
            //success, decode rest of packet 
            int plength = (0xff * ReceiveBufferA[1]) + ReceiveBufferA[2]; //length of packet is... 
 
            //listen for rest of packet 
            byte[] ReceiveBufferB = new byte[plength - 3]; 
            stream.Read(ReceiveBufferB, 0, plength - 3); 
 
            int obver = ReceiveBufferB[0]; //server obex version (16 = v1.0) 
            int cflags = ReceiveBufferB[1]; //connect flags 
            int maxpack = (0xff * ReceiveBufferB[2]) + ReceiveBufferB[3]; //max packet size 
 
            return true; 
        } 
        else 
        { 
            return false; 
        } 
    } 
    #endregion 
 
    #region OBEXRequest 
    private int OBEXRequest(string tReqType, string tName, string tType, string tFileContent) 
{ 
        //send client request 
 
        int i; 
        int offset; 
        int packetsize; 
        byte reqtype = 0x82; 
 
        int tTypeLen = 0x03; 
        int typeheadsize; 
        int typesizeHi = 0x00; 
        int typesizeLo = 0x03; 
 
        //tName = "contact.vcf"; 
        //tType = "text/x-vCard"; 
        //tFileContent = "BEGIN:VCARD\r\nVERSION:2.1\r\nN:;aardvark\r\nFN:aardvark\r\nEND:VCARD\r\n"; 
 
        if (tReqType == "GET") 
        { 
            reqtype = 0x83;      // 131 GET-Final 
        } 
 
        if (tReqType == "PUT") 
        { 
            reqtype = 0x82;      // 130 PUT-Final 
        } 
 
        packetsize = 3; 
 
        //Name Header 
        int tNameLength = tName.Length; 
        int nameheadsize = (3 + (tNameLength * 2) + 2); 
        int namesizeHi = (nameheadsize & 0xff00) / 0xff; 
        int namesizeLo = nameheadsize & 0x00ff; 
        packetsize = packetsize + nameheadsize; 
 
        if (tType != "") 
        { 
            //Type Header 
            tTypeLen = tType.Length; 
            typeheadsize = 3 + tTypeLen + 1; 
            typesizeHi = (typeheadsize & 0xff00) / 0xff; 
            typesizeLo = typeheadsize & 0x00ff; 
            packetsize = packetsize + typeheadsize; 
        } 
 
        //Body 
        int fileLen = System.Text.Encoding.Default.GetBytes(tFileContent).Length;//tFileContent.Length; 
        int fileheadsize = 3 + fileLen; 
        int filesizeHi = (fileheadsize & 0xff00) / 0xff; ; 
        int filesizeLo = fileheadsize & 0x00ff; ; 
 
        packetsize = packetsize + fileheadsize; 
 
        int packetsizeHi = (packetsize & 0xff00) / 0xff; 
        int packetsizeLo = packetsize & 0x00ff; 
 
        byte[] tSendByte = new byte[packetsize]; 
 
        //PUT-final Header 
        tSendByte[0] = reqtype;                    // Request type e.g. PUT-final 130 
        tSendByte[1] = Convert.ToByte(packetsizeHi);        // Packetlength Hi 
        tSendByte[2] = Convert.ToByte(packetsizeLo);        // Packetlength Lo 
 
        offset = 2; 
 
        //Name Header 
        tSendByte[offset + 1] = 0x01;                  // HI for Name header     
        tSendByte[offset + 2] = Convert.ToByte(namesizeHi);      // Length of Name header (2 bytes per char) 
        tSendByte[offset + 3] = Convert.ToByte(namesizeLo);      // Length of Name header (2 bytes per char) 
 
        // Name+\n\n in unicode 
        byte[] tNameU = System.Text.Encoding.BigEndianUnicode.GetBytes(tName); 
        tNameU.CopyTo(tSendByte, offset + 4); 
 
        offset = offset + 3 + (tNameLength * 2); 
        tSendByte[offset + 1] = 0x00;                  // null term 
        tSendByte[offset + 2] = 0x00;                  // null term 
 
        offset = offset + 2; 
 
        if (tType != "") 
        { 
            //Type Header 
            tSendByte[offset + 1] = 0x42;                  // HI for Type Header 66 
            tSendByte[offset + 2] = Convert.ToByte(typesizeHi);      // Length of Type Header 
            tSendByte[offset + 3] = Convert.ToByte(typesizeLo);      // Length of Type Header 
 
            for (i = 0; i <= (tTypeLen - 1); i++) 
            { 
                tSendByte[offset + 4 + i] = Convert.ToByte(Convert.ToChar(tType.Substring(i, 1))); 
            } 
            tSendByte[offset + 3 + tTypeLen + 1] = 0x00;            // null terminator 
 
            offset = offset + 3 + tTypeLen + 1; 
        } 
 
        //Body 
        tSendByte[offset + 1] = 0x49;                  //HI End of Body 73 
        tSendByte[offset + 2] = Convert.ToByte(filesizeHi);      // 
        tSendByte[offset + 3] = Convert.ToByte(filesizeLo);      //1k payload + 3 for HI header 
 
        //for (i = 0; i <= (fileLen - 1); i++) 
        //{ 
        //    tSendByte[offset + 4 + i] = Convert.ToByte(tFileContent.Substring(i, 1));//Convert.ToByte(Convert.ToChar(tFileContent.Substring(i, 1))); 
        //} 
        byte[] bfile = System.Text.Encoding.Default.GetBytes(tFileContent); 
        for (i = 0; i <= bfile.Length - 1; i++) 
        { 
            tSendByte[offset + 4 + i] = bfile[i]; 
        } 
 
        //tSendByte[offset+4+fileLen] = 0x00;              // null terminator 
 
        offset = offset + 3 + fileLen; 
 
        stream.Write(tSendByte, 0, tSendByte.Length); 
 
        //listen for server response 
 
        //TODO: can hang here forever waiting response... 
 
        bool x = stream.DataAvailable; // changed bluetoothclient - public NetworkStream GetStream() 
 
        byte[] tArray4 = new byte[3]; 
        stream.Read(tArray4, 0, 3); 
 
        x = stream.DataAvailable; 
 
        if (tArray4[0] == 160) // 0xa0 
        { 
            int plength = (tArray4[1] * 256) + tArray4[2] - 3; 
            byte[] tArray5 = new byte[plength]; 
            if (plength > 0) 
            { 
                stream.Read(tArray5, 0, plength); 
                //TODO: data in returned packet to deal with 
            } 
            return 160; 
        } 
 
        if (tArray4[0] == 197) // 0xc5 Method not allowed 
        { 
            return 197; 
        } 
 
        if (tArray4[0] == 192) // 0xc0 Bad Request 
        { 
            return 192; 
        } 
 
        return 0; 
    } 
 
    #endregion 
}

責(zé)任編輯：武曉燕來(lái)源：后端Q

C# PC 藍(lán)牙