2

我正在尝试使用新的 android wear comms API，特别是 Message API，我的手表应用程序中有一个 Activity 和一个服务，还有一个 Activity 作为手机中的测试应用程序。

我的通讯在两个方向上都可以正常工作，我可以通过从电话应用程序发送消息来通过通讯启动我的手表活动，这也可以正常工作，除了一个问题，它只在手表硬件重启后立即发生：

如果我在重新启动后立即通过通讯消息调用启动我的 Watch 应用程序，而没有首先运行 Watch App Activity，那么从 Watch 返回的消息回复将丢失并且电话应用程序看不到。

如果我在重启后和从电话应用程序启动通信之前在手表应用程序中运行一个活动，那么通信消息工作正常，即使我在发送任何消息之前关闭手表活动也是如此。

我在 Watch 端的 WearableListenerService 代码如下所示（非常简略）

public class MyClass extends WearableListenerService
                        implements MessageApi.MessageListener,
                                   ConnectionCallbacks,
                                   OnConnectionFailedListener
{

...

@Override
public void onCreate()
{
   mGoogleApiClient = new GoogleApiClient.Builder(this)
                                          .addApi(Wearable.API)
                                          .build();
}

@Override
public void onDestroy()
{
    mGoogleApiClient.disconnect();

   super.onDestroy();
}

@Override
public int onStartCommand(Intent intent, int flags, int startId) 
{
    int result = super.onStartCommand(intent, flags, startId);
    mGoogleApiClient.connect();

    return result;
}

@Override
public void onMessageReceived(MessageEvent messageEvent)
{
    comms.handleReceivedMessage (messageEvent);
}

public final void txReply(String txMessage, String nodeId)
{
    Wearable.MessageApi.sendMessage(mGoogleApiClient, 
                                    nodeId,
                                    MESSAGE_RECEIVED_PATH, 
                                    txMessage.getBytes());
}

@Override
public void onConnected(Bundle bundle)
{
    Wearable.MessageApi.addListener(mGoogleApiClient, this);
}

@Override
public void onConnectionSuspended(int arg0) 
{
    // TODO Auto-generated method stub
}

@Override
public void onConnectionFailed(ConnectionResult arg0) 
{
    // TODO Auto-generated method stub
}

}

我的 comms.handleReceivedMessage() 函数直接调用了上面的 txReply() 函数，并且我已经使用 LogCat 验证了数据是正确的。

我将非常感谢任何关于我可能遗漏的内容的指示，这会阻止电话应用程序接收到我的第一条 Watch App 消息。同样，如果在收到消息之前未运行 Watch App Activity，则此行为仅在重新启动后立即发生。

--编辑--@墨菲：

好吧，我查看了您的代码，它似乎与我已经拥有的几乎相同，实际上我有以下代替您的电话：

NodeApi.GetConnectedNodesResult nodes = Wearable.NodeApi.getConnectedNodes(mGoogleApiClient).await();
for (Node node : nodes.getNodes()) 
{
    // Send message and wait for result
    SendMessageResult result = Wearable.MessageApi.sendMessage(mGoogleApiClient, 
                                                               node.getId(),
                                                               MESSAGE_RECEIVED_PATH, 
                                                               txm.getBytes()).await();
}

因此，就手表丢失的通信而言，差异并不显着，但无论如何感谢您的帮助。

问候，

4

2 回答 2

1

首先，您不需要为消息 API 添加Listener 并实现 MessageApi.MessageListener，因为 WearableListenerService 会为您完成，您只需覆盖方法 onMessageReceived。

至于问题，你应该确保连接了google api（我上面提到，WearableListenerService是由系统管理的，所以你可以在你的api客户端连接之前收到一条消息）：

public final void txReply(String txMessage, String nodeId)
{
    if (!mGoogleApiClient.isConnected()) 
    {
            ConnectionResult connectionResult 
                         = mGoogleApiClient.blockingConnect(30, TimeUnit.SECONDS);
            if (!connectionResult.isSuccess()) {
                //log or show error
                return;
            }
    }
    Wearable.MessageApi.sendMessage(mGoogleApiClient, 
                                nodeId,
                                MESSAGE_RECEIVED_PATH, 
                                txMessage.getBytes());
}
于 2014-10-27T02:51:15.157 回答
0

连接googleApiClient并不能确保您与您的Wear.

我建议您在发送之前检查手机端的Wear连接Message：

Wearable.NodeApi.getConnectedNodes(getGoogleApiClient()).setResultCallback(new ResultCallback<NodeApi.GetConnectedNodesResult>() {
    @Override
    public void onResult(NodeApi.GetConnectedNodesResult getConnectedNodesResult) {
        boolean isPeerConnected = getConnectedNodesResult.getNodes().size() > 0;
}});

编辑：如果它没有连接，那么我可以在连接时发送：

Wearable.NodeApi.addListener(getGoogleApiClient(), new NodeApi.NodeListener() {
    @Override
    public void onPeerConnected(Node node) {
        // TODO send message
    }

    @Override
    public void onPeerDisconnected(Node node) {

    }
})
于 2014-10-21T08:04:50.430 回答