从PC作为客户端通过蓝牙向移动设备作为服务器发送字符串

22
我需要帮助,通过蓝牙将字符串从PC传输到Android移动设备。 Android移动设备应充当服务器,并在设备屏幕上显示字符串消息。客户端的PC应将字符串发送到移动设备。
我希望服务器对提取的字符串做出反应(通过蓝牙传输)。这意味着一方面服务器必须始终监听新的字符串到达,但另一方面仍然必须能够对这些消息做出反应(例如,从一个菜单导航到另一个菜单)。
我尝试使用BlueCove(2.1.1)作为BluetoothStack(我将来自BlueCove的jar库添加到两个项目中)与我在here找到的服务器-客户端通信示例相结合。
更新: 感谢用户CC,使用RFComm连接更新了服务器代码:
public class RFCommServer extends Thread{

//based on java.util.UUID
private static UUID MY_UUID = UUID.fromString("446118f0-8b1e-11e2-9e96-0800200c9a66");

// The local server socket
private BluetoothServerSocket mmServerSocket;

// based on android.bluetooth.BluetoothAdapter
private BluetoothAdapter mAdapter;
private BluetoothDevice remoteDevice;

private Activity activity;

public RFCommServer(Activity activity) {
    this.activity = activity;
}

public void run() {
    BluetoothSocket socket = null;
    mAdapter = BluetoothAdapter.getDefaultAdapter();        

    // Listen to the server socket if we're not connected
    while (true) {

        try {
            // Create a new listening server socket
            Log.d(this.getName(), ".....Initializing RFCOMM SERVER....");

            // MY_UUID is the UUID you want to use for communication
            mmServerSocket = mAdapter.listenUsingRfcommWithServiceRecord("MyService", MY_UUID);
            //mmServerSocket = mAdapter.listenUsingInsecureRfcommWithServiceRecord(NAME, MY_UUID); // you can also try using In Secure connection...

            // This is a blocking call and will only return on a
            // successful connection or an exception
            socket = mmServerSocket.accept();

        } catch (Exception e) {

        }

        try {
            Log.d(this.getName(), "Closing Server Socket.....");
            mmServerSocket.close();

            InputStream tmpIn = null;
            OutputStream tmpOut = null;

            // Get the BluetoothSocket input and output streams

            tmpIn = socket.getInputStream();
            tmpOut = socket.getOutputStream();

            DataInputStream mmInStream = new DataInputStream(tmpIn);
            DataOutputStream mmOutStream = new DataOutputStream(tmpOut);

            // here you can use the Input Stream to take the string from the client whoever is connecting
            //similarly use the output stream to send the data to the client

            RelativeLayout layout = (RelativeLayout) activity.findViewById(R.id.relativeLayout_Layout);
            TextView text = (TextView) layout.findViewById(R.id.textView_Text);

            text.setText(mmInStream.toString());
        } catch (Exception e) {
            //catch your exception here
        }
    }
}

这里是SPP客户端的代码:here

/**
* A simple SPP client that connects with an SPP server
*/
public class SampleSPPClient implements DiscoveryListener{

//object used for waiting
private static Object lock=new Object();

//vector containing the devices discovered
private static Vector vecDevices=new Vector();

private static String connectionURL=null;

public static void main(String[] args) throws IOException {

    SampleSPPClient client=new SampleSPPClient();

    //display local device address and name
    LocalDevice localDevice = LocalDevice.getLocalDevice();
    System.out.println("Address: "+localDevice.getBluetoothAddress());
    System.out.println("Name: "+localDevice.getFriendlyName());

    //find devices
    DiscoveryAgent agent = localDevice.getDiscoveryAgent();

    System.out.println("Starting device inquiry...");
    agent.startInquiry(DiscoveryAgent.GIAC, client);

    try {
        synchronized(lock){
            lock.wait();
        }
    }
    catch (InterruptedException e) {
        e.printStackTrace();
    }


    System.out.println("Device Inquiry Completed. ");

    //print all devices in vecDevices
    int deviceCount=vecDevices.size();

    if(deviceCount <= 0){
        System.out.println("No Devices Found .");
        System.exit(0);
    }
    else{
        //print bluetooth device addresses and names in the format [ No. address (name) ]
        System.out.println("Bluetooth Devices: ");
        for (int i = 0; i <deviceCount; i++) {
            RemoteDevice remoteDevice=(RemoteDevice)vecDevices.elementAt(i);
            System.out.println((i+1)+". "+remoteDevice.getBluetoothAddress()+" ("+remoteDevice.getFriendlyName(true)+")");
        }
    }

    System.out.print("Choose Device index: ");
    BufferedReader bReader=new BufferedReader(new InputStreamReader(System.in));

    String chosenIndex=bReader.readLine();
    int index=Integer.parseInt(chosenIndex.trim());

    //check for spp service
    RemoteDevice remoteDevice=(RemoteDevice)vecDevices.elementAt(index-1);
    UUID[] uuidSet = new UUID[1];
    uuidSet[0]=new UUID("446118f08b1e11e29e960800200c9a66", false);

    System.out.println("\nSearching for service...");
    agent.searchServices(null,uuidSet,remoteDevice,client);

    try {
        synchronized(lock){
            lock.wait();
        }
    }
    catch (InterruptedException e) {
        e.printStackTrace();
    }

    if(connectionURL==null){
        System.out.println("Device does not support Simple SPP Service.");
        System.exit(0);
    }

    //connect to the server and send a line of text
    StreamConnection streamConnection=(StreamConnection)Connector.open(connectionURL);

    //send string
    OutputStream outStream=streamConnection.openOutputStream();
    PrintWriter pWriter=new PrintWriter(new OutputStreamWriter(outStream));
    pWriter.write("Test String from SPP Client\r\n");
    pWriter.flush();


    //read response
    InputStream inStream=streamConnection.openInputStream();
    BufferedReader bReader2=new BufferedReader(new InputStreamReader(inStream));
    String lineRead=bReader2.readLine();
    System.out.println(lineRead);


}//main

//methods of DiscoveryListener
public void deviceDiscovered(RemoteDevice btDevice, DeviceClass cod) {
    //add the device to the vector
    if(!vecDevices.contains(btDevice)){
        vecDevices.addElement(btDevice);
    }
}

//implement this method since services are not being discovered
public void servicesDiscovered(int transID, ServiceRecord[] servRecord) {
    if(servRecord!=null && servRecord.length>0){
        connectionURL=servRecord[0].getConnectionURL(0,false);
    }
    synchronized(lock){
        lock.notify();
    }
}

//implement this method since services are not being discovered
public void serviceSearchCompleted(int transID, int respCode) {
    synchronized(lock){
        lock.notify();
    }
}


public void inquiryCompleted(int discType) {
    synchronized(lock){
        lock.notify();
    }

}//end method

}

为了测试,我使用了最新的Android API的Galaxy Nexus (GT-I9250)。
感谢user_CC,客户端和服务器现在都可以正常运行,没有异常。但不幸的是,客户端无法连接到服务器(请参见下面的截图)。这是因为connectionURL从未设置(因此默认情况下会跳转到if(connectionURL==null))。
我该如何更改客户端代码,以便我实际上可以将其连接到服务器?我需要在以下行中正确设置connectionURL:
StreamConnection streamConnection=(StreamConnection)Connector.open(connectionURL)

到目前为止,我只发现我需要以某种方式获取ServiceRecord,可惜这也没有在here的示例代码中描述。

enter image description here


关于设计的说明。根据您想要做什么,让Android设备发起连接可能(或可能不)更有意义。一旦连接,PC仍然能够启动数据传输,即向Android设备发送应在屏幕上显示的消息。唯一的区别是谁在连接。但我不知道您正在构建什么,所以这只是一个建议。 - TimothyP
嗯,你说得对,我会改变这个。你的代码示例可以完成这个吗?连接是通过socket.Connect()建立的吗? - Elementary
2个回答

8

您需要使用RFComm APIS才能使通信工作。我已经定义了一个类,它是一个线程,并且将作为服务器并监听客户端连接。我还为您放置了一些注释以便理解。

    private class AcceptThread extends Thread {
    // The local server socket
    private BluetoothServerSocket mmServerSocket;

    public AcceptThread() {
    }

    public void run() {         
        BluetoothSocket socket = null;

                    BluetoothAdapter mAdapter = BluetoothAdapter.getDefaultAdapter();

        // Listen to the server socket if we're not connected
        while (true) {

            try {
                // Create a new listening server socket
                Log.d(TAG, ".....Initializing RFCOMM SERVER....");

                // MY_UUID is the UUID you want to use for communication
                mmServerSocket = mAdapter.listenUsingRfcommWithServiceRecord(NAME, MY_UUID);                    
                //mmServerSocket = mAdapter.listenUsingInsecureRfcommWithServiceRecord(NAME, MY_UUID);  you can also try using In Secure connection...

                // This is a blocking call and will only return on a
                // successful connection or an exception                    
                socket = mmServerSocket.accept();                   

            } catch (Exception e) {

            }

            try {
                Log.d(TAG, "Closing Server Socket.....";                    
                mmServerSocket.close();



                InputStream tmpIn = null;
                OutputStream tmpOut = null;

                // Get the BluetoothSocket input and output streams

                tmpIn = socket.getInputStream();
                tmpOut = socket.getOutputStream();


                mmInStream = new DataInputStream(tmpIn);
                mmOutStream = new DataOutputStream(tmpOut); 

                // here you can use the Input Stream to take the string from the client whoever is connecting
                //similarly use the output stream to send the data to the client
            } catch (Exception e) {
                //catch your exception here
            }

        }
    }

}

我希望这能有所帮助。
针对你的另一个问题:
在客户端(PC)声明javax.bluetooth.UUID,UUID类应该来自javax.bluetooth.UUID。
   uuidSet2[0] = new UUID("446118f08b1e11e29e960800200c9a66", false);

在服务器端(Android)声明java.util.UUID
    UUID MY_UUID = UUID.fromString("446118f0-8b1e-11e2-9e96-0800200c9a66");

你在创建UUID对象时出现异常了,是吗?另外,能否分享一下日志... - user_CC
是的,当我使用bluecove API提供的方法创建UUID对象时,我遇到了错误。我更新了我的帖子,但不幸的是没有日志被创建(在Eclipse中的errorlog),但错误会在控制台中显示,希望这可以帮助解决问题。 - Elementary

2

虽然我不是Java开发人员,但我在Mono for Android (c#)中遇到了类似的问题。

SPP的UUID应该为"00001101-0000-1000-8000-00805F9B34FB",这是一个用于识别蓝牙SPP适配器的众所周知的UID。

我的c#代码如下:

private static UUID MY_UUID = UUID.FromString("00001101-0000-1000-8000-00805F9B34FB");

我猜您可以将Java代码更新为以下内容:

我猜您可以将Java代码更新为以下内容:

new UUID("00001101-0000-1000-8000-00805F9B34FB", true);

虽然我不确定该函数接受哪些参数,所以你可能需要检查一下。

我使用的是Android设备作为客户端,但这些信息可能对您有用,
因此我在这里包含了我的C#代码,我最初是从Java示例中翻译过来的,
所以你应该能够将其翻译回去:

btAdapter = BluetoothAdapter.DefaultAdapter;

btAdapter.CancelDiscovery(); //Always call CancelDiscovery before doing anything
remoteDevice = btAdapter.GetRemoteDevice(Settings["deviceaddress"].ToString());

socket = remoteDevice.CreateRfcommSocketToServiceRecord(MY_UUID);
socket.Connect();

基本上,我会获取默认适配器,取消任何正在运行的发现操作,然后创建到其他设备的套接字。在您的情况下,您将希望侦听而不是连接,但这只是供您参考。
希望这可以帮助您,很抱歉我无法提供更多的Java特定信息。
“更新:”刚刚在Java中找到了一个小示例,它更或多或少地遵循了我正在使用的相同方法:Problems with connecting bluetooth SPP in android?

网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接