3

我正在尝试将文件从我的 Google wear 发送到我的 Nexus 5。我已经阅读了一些教程并想出了以下代码，但我的手机没有收到文件。

移动的：

private GoogleApiClient mGoogleApiClient;
private int count = 0;

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_main);

    mGoogleApiClient = new GoogleApiClient.Builder(this)
            .addApi(Wearable.API)
            .addConnectionCallbacks(this)
            .addOnConnectionFailedListener(this)
            .build();

    Log.d(TAG, "CONNECTING:");

    mGoogleApiClient.connect();
}

@Override
protected void onResume() {
    super.onStart();
}

@Override
public void onConnected(Bundle bundle) {
    Log.d(TAG, "CONNECTED");
    Toast.makeText(getApplicationContext(), "Connected.",
            Toast.LENGTH_LONG).show();
    Wearable.DataApi.addListener(mGoogleApiClient, this);
}

@Override
public void onConnectionSuspended(int i) {

}

@Override
protected void onPause() {
    super.onPause();
    Wearable.DataApi.removeListener(mGoogleApiClient, this);
    mGoogleApiClient.disconnect();
}

@Override
public void onDataChanged(DataEventBuffer dataEvents) {
    Toast.makeText(getApplicationContext(), "Data changed.",
            Toast.LENGTH_LONG).show();
    for (DataEvent event : dataEvents) {
        if (event.getType() == DataEvent.TYPE_CHANGED &&
                event.getDataItem().getUri().getPath().equals("/txt")) {
            // Get the Asset object
            DataMapItem dataMapItem = DataMapItem.fromDataItem(event.getDataItem());
            Asset asset = dataMapItem.getDataMap().getAsset("sensordataAsset");
            Log.d(TAG, "");

            ConnectionResult result =
                    mGoogleApiClient.blockingConnect(10000, TimeUnit.MILLISECONDS);
            if (!result.isSuccess()) {
                return;
            }

            // Convert asset into a file descriptor and block until it's ready
            InputStream assetInputStream = Wearable.DataApi.getFdForAsset(
                    mGoogleApiClient, asset).await().getInputStream();
            mGoogleApiClient.disconnect();
            if (assetInputStream == null) {
                return;
            }

            // Get folder for output
            File storage = getApplicationContext().getFilesDir();
            Log.d(TAG, "Location:" + storage.toString());
            File dir = new File(storage.getAbsolutePath() + "/Clockwork/");
            if (!dir.exists()) {
                dir.mkdirs();
            } // Create folder if needed
            Log.d(TAG, dir.getAbsolutePath());

            // Read data from the Asset and write it to a file on external storage
            final File file = new File(dir, "sensordata.txt");
            if (!file.exists()) {
                file.mkdirs();
            }
            Log.d(TAG, file.getPath());

            try {
                FileOutputStream fOut = new FileOutputStream(file);
                int nRead;
                byte[] data = new byte[16384];
                while ((nRead = assetInputStream.read(data, 0, data.length)) != -1) {
                    fOut.write(data, 0, nRead);
                }

                fOut.flush();
                fOut.close();
            } catch (Exception e) {
            }

            // Rescan folder to make it appear
            try {
                String[] paths = new String[1];
                paths[0] = file.getAbsolutePath();
                MediaScannerConnection.scanFile(this, paths, null, null);
            } catch (Exception e) {
            }
        }
    }
}

@Override
public void onConnectionFailed(ConnectionResult connectionResult) {

}

穿：

public void sendTextFile() {

    readFromFile();
    FileInputStream fileInputStream = null;

    byte[] bFile = new byte[(int) file.length()];
    try {
        fileInputStream = new FileInputStream(file);
        fileInputStream.read(bFile);
        fileInputStream.close();
    } catch (Exception e) {
        Log.e(TAG, "sendTextFile: " + e.toString());
    }

    connectGoogleApi();
    //Create an Asset from the byte array and set it via the DataApi
    Asset asset = Asset.createFromBytes(bFile);
    PutDataMapRequest dataMap = PutDataMapRequest.create("/txt");
    dataMap.getDataMap().putAsset("sensordataAsset", asset);
    PutDataRequest request = dataMap.asPutDataRequest();
    PendingResult<DataApi.DataItemResult> pendingResult = Wearable.DataApi
            .putDataItem(mGoogleApiClient, request);

}
private void connectGoogleApi() {
    mGoogleApiClient = new GoogleApiClient.Builder(context)
            .addApi(Wearable.API)
            .addConnectionCallbacks(this)
            .addOnConnectionFailedListener(this)
            .build();
    mGoogleApiClient.connect();
}

@Override
public void onConnected(Bundle bundle) {
    Log.d(TAG, "CONNECTED");
    Toast.makeText(context, "Connected.",
            Toast.LENGTH_LONG).show();
}

@Override
public void onConnectionSuspended(int i) {

}

@Override
public void onConnectionFailed(ConnectionResult connectionResult) {

}

我用上面列出的方法制作了一个记录器。有人可以告诉我我做错了什么。提前致谢。

4

3 回答 3

0

在datamap中添加一个key值：map.put("timestamp", System.currentmillions()) 你的手机没有收到任何change事件，因为你把同一个数据项放到了data api队列中，试着放一个不同的项

于 2015-03-05T04:32:23.073 回答
0

我通过替换它来解决它

PutDataRequest putDataRequest = PutDataRequest.create("/image");
putDataRequest.putAsset("debugFile", asset);
Wearable.DataApi.putDataItem(client, putDataRequest);

有了这个

PutDataMapRequest dataMap = PutDataMapRequest.create("/image");
dataMap.getDataMap().putAsset("debugFile", asset);
PutDataRequest request = dataMap.asPutDataRequest();
PendingResult<DataItemResult> pendingResult = Wearable.DataApi.putDataItem(client, request);
pendingResult.setResultCallback(new ResultCallback<DataItemResult> () {
    @Override
    public void onResult(DataItemResult dataItemResult) {
        // something 
    }
} );

现在它对我有用

于 2015-06-02T11:12:19.673 回答
0

主要错误：

        // Read data from the Asset and write it to a file on external storage
        final File file = new File(dir, "sensordata.txt");
        if (!file.exists()) {
            file.mkdirs(); <---- you create a directory instead a file
        }

这就是为什么您看不到错误的原因。

            fOut.flush();
            fOut.close();
        } catch (Exception e) { <--- hide exception
        }

文件作为目录存在，无法打开流

   FileOutputStream fOut = new FileOutputStream(file); <-- throw exception
于 2015-06-16T15:57:42.550 回答