0

我正在尝试使用 Android SPP 蓝牙插座接口以“尽可能接近”的方式实时控制/操作 Android 手机上的电机。电机应该以所谓的“死人”操作模式运行。所以电机只有在android APP上的一个按钮被触摸时才会转动，如果触摸被释放则应该立即停止。

我通过大约每 20 毫秒连续发送 20 字节的“保持转动”电报来实现这一点，以保持电机转动，并在没有收到更多电报或收到停止电报时立即停止电机。

这在某些手机上似乎可以接受，但其他手机即使在处理 MotionEvent.ACTION_UP 事件并且不再发送数据之后仍继续发送“继续转动”电报。

我假设这是由一些缓存传输数据并继续发送直到缓冲区为空的内部缓冲区引起的。

简单的问题：

  • 有没有办法清除 BT 流传输缓冲区以立即停止所有数据传输？
  • 或者我可以得到传输缓冲区的填充水平，在这种情况下我不会将超过 2 个电报放入其中？
  • 或者有没有办法在打开流时指定缓冲区大小？

在网上搜索，我找不到任何关于缓冲区管理的 BT 流缓冲区大小的内容。

是的，我已经将读写功能实现为线程，我在阅读所有电报时没有任何问题，我不需要实时发送电报，但我应该能够停止发送“继续转动”电报约50 到 100 毫秒。

任何提示都非常受欢迎。

4

1 回答 1

0

很抱歉我没有添加代码，我认为可能没有必要，因为它很简单：

    @Override
    public boolean onTouch(final View v,MotionEvent event) {
        int eventAction = event.getAction();

        switch (eventAction) {
            case MotionEvent.ACTION_DOWN:
                if (v == btnUp || v == btnDown) {

                    // Start a thread that sends the goUP or DOWN command every 10 ms until
                    // btnUp released

                    tvCounter.setText("----");
                    action_touched = true;

                    new Thread(new Runnable() {
                        @Override
                        public void run() {
                            int counter = 1;

                            // Disable heart beat
                            ServiceRequest.send(EnRequest.REQ_SET_HEARTBEAT,0);

                            // Send GoUp command plus a wrapping counter byte every nn ms
                            // until the button is released

                            while (action_touched) {
                                try {
                                    setDeadmanMove(v==btnUp,counter);
                                    Thread.sleep(20);
                                    ++counter;
                                }
                                catch (InterruptedException ex) {
                                    action_touched = false;
                                }
                                catch (Exception ex) {
                                    action_touched = false;
                                }
                            }

                            // Send a STOP command
                            setDeadmanStop();

                            // Enable heart beat again
                            ServiceRequest.send(EnRequest.REQ_SET_HEARTBEAT,1);

                            // We are done
                        }
                    }).start();
                }
                break;

            case MotionEvent.ACTION_UP:
                // Stop Thread
                action_touched = false;
                break;
        }
        return true;
    }

下面的片段是管理蓝牙串行通信的通信类的一部分。

 public void btWrite(DeviceRecord message) {
     if (runBTreceiver) {

         if (message.isValidRecord()) {
             try {

                 lock.lock();
                 ++lockCounter;
                 mmBufferedOut.write(message.getFullRecord());
                 mmBufferedOut.flush();
             }
             catch (IOException e) {
                 if (GlobalData.isDebugger) Log.i(TAG, "Failed sending " + message + " " + e.getMessage());
                 ServiceResponse.send(EnEvent.EVT_BT_RECEIVER_ERROR, "Error data send: " + e.getMessage());
                 resetConnection();
                 runBTreceiver=false;
             }
             finally {
                 --lockCounter;
                 lock.unlock();
             }
         }
     }
 }

分配并打开蓝牙连接的代码片段

try {
    // Set up a pointer to the remote node using it's address.
    BluetoothDevice device = myBluetoothAdapter.getRemoteDevice(myBluetoothMacId);
    if (device != null)
    {
        // Two things are needed to make a connection:
        // A MAC address, which we got above.
        // A Service ID or UUID. In this case we are using the
        // UUID for SPP.

        try {
            myBluetoothSocket = device.createRfcommSocketToServiceRecord(GlobalData.MY_UUID);
        }
        catch (IOException e) {
            sendEventStatus(EnEvent.EVT_BTADAPTER_FAIL,
                    String.format(GlobalData.rString(R.string.srv_failcrt),BTERROR_CREATE,e.getMessage()));
        }

        // Establish the connection. This will block until it connects or
        // timeout?

        try {
            if (! myBluetoothSocket.isConnected()) {
                myBluetoothSocket.connect();
            }
        }
        catch (IOException e) {
            try {
                Log.e("","trying fallback...");

                myBluetoothSocket =(BluetoothSocket) device.getClass().getMethod("createRfcommSocket", new Class[] {int.class}).invoke(device,1);
                myBluetoothSocket.connect();
            }
            catch (IOException e2) {
                sendEventStatus(EnEvent.EVT_BTADAPTER_FAIL,e2.getMessage());
            }
        }
    }
    else {
        sendEventStatus(EnEvent.EVT_BTADAPTER_FAIL,
                String.format(GlobalData.rString(R.string.srv_failcrt),BTERROR_DEVICE,"getRemoteDevice failed"));
    }
}
catch (Exception e) {
    sendEventStatus(EnEvent.EVT_BTADAPTER_FAIL, e.getMessage());
    return;
}
InputStream tmpIn = null;
OutputStream tmpOut = null;

mmSocket = socket;

// Get the input and output streams, using temp objects because
// member streams are final

try {
    tmpIn = socket.getInputStream();
    tmpOut = socket.getOutputStream();
}
catch (IOException e) {
    ServiceResponse.send(EnEvent.EVT_ERROR, GlobalData.rString(R.string.srv_failcst) + e.getMessage());
    resetConnection();
    runBTreceiver=false;
}
mmInStream = tmpIn;
// mmOutStream = tmpOut;
mmBufferedOut = new BufferedOutputStream(tmpOut,80);

// Initial request
btWrite(new DeviceRecord(0, 4));

我从未发现通过此代码发送和接收数据的任何问题。所有记录均已正确发送和接收。唯一的问题是我无法在释放操作按钮的那一刻清除传输缓冲区。

为了克服这个问题，我改变了协议，一次只发送一个“继续转动”电报，下一个电报将在另一端的响应（某种握手）后发送，然后程序继续运行这个 ping/pong 直到按钮被释放。这种方法效果很好，因为传输缓冲区一次永远不会保存超过一个电报。

上述问题已解决，但我仍然不知道是否可以清除传输缓冲区

于 2015-01-11T13:02:01.963 回答