个人中心
文章发布
退出
作者热门文章
- iOS/Objective-C 元类和类别
- objective-c - -1001 错误，当 NSURLSession 通过 httpproxy 和/etc/hosts
- java - 使用网络类获取 url 地址
- ios - 推送通知中不播放声音
25
4
我正在尝试从欧姆龙 708-BT 血压监测仪读取数据，该监测仪已通过 continua 健康联盟认证。我正在关注这个例子 of a Bluetooth HDP App .我设法连接到设备并以字节格式检索数据，但无法解析数据以获取所需的值。我试图遵循此 PDF 第 19 页指定的 IEEE 血压规范.
这是添加到上面链接的示例代码中的代码。
//Variables in the class
private int count;
private byte[] invoke = {0x00, 0x00};
private class ReadThread extends Thread {
private ParcelFileDescriptor mFd;
public ReadThread(ParcelFileDescriptor fd) {
super();
mFd = fd;
}
@Override
public void run() {
FileInputStream fis = new FileInputStream(mFd.getFileDescriptor());
final byte data[] = new byte[300];
try {
while(fis.read(data) > -1) {
// At this point, the application can pass the raw data to a parser that
// has implemented the IEEE 11073-xxxxx specifications. Instead, this sample
// simply indicates that some data has been received
Log.e("Test", data.toString());
if (data[0] != (byte) 0x00)
{
String test = byte2hex(data);
Log.i(TAG, test);
if(data[0] == (byte) 0xE2){
Log.i(TAG, "E2");
count = 1;
(new WriteThread(mFd)).start();
try {
sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
Log.i(TAG, "Seconds Write Thread");
count = 2;
(new WriteThread(mFd)).start();
}
else if (data[0] == (byte)0xE7){
Log.i(TAG, "E7");
count = 3;
//set invoke id so get correct response
invoke = new byte[] { data[6], data[7] };
(new WriteThread(mFd)).start();
//parse data!!
int number_of_data_packets = data[25];
int packet_start = 30;
final int SYS_DIA_MAP_DATA = 1;
final int PULSE_DATA = 2;
final int ERROR_CODE_DATA = 3;
for (int i = 0; i < number_of_data_packets; i++){
Log.e("TEST", Integer.toString(i));
int obj_handle = data[packet_start+1];
switch (obj_handle)
{
case SYS_DIA_MAP_DATA:
int sys = byteToUnsignedInt(data[packet_start+9]);
int dia = byteToUnsignedInt(data[packet_start+11]);
int map = byteToUnsignedInt(data[packet_start+13]);
//create team string... 9+13~9+20
Log.e("RESULT", "sys is "+ sys);
sendMessage(RECEIVED_SYS, sys);
Log.e("RESULT", "dia is "+ dia);
sendMessage(RECEIVED_DIA, dia);
Log.e("RESULT", "map is "+ map);
break;
case PULSE_DATA:
//parse
int pulse = byteToUnsignedInt(data[packet_start+5]);
Log.e("RESULT", "pulse is " + pulse);
sendMessage(RECEIVED_PUL, pulse);
break;
case ERROR_CODE_DATA:
//need more signal
break;
}
packet_start += 1;//4 + data[packet_start+3]; //4 = ignore beginning four bytes
}
}
else if (data[0] == (byte) 0xE4)
{
count = 4;
(new WriteThread(mFd)).start();
}
//zero out the data
for (int i = 0; i < data.length; i++){
data[i] = (byte) 0x00;
}
}
sendMessage(STATUS_READ_DATA, 0);
}
} catch(IOException ioe) {}
if (mFd != null) {
try {
mFd.close();
} catch (IOException e) { /* Do nothing. */ }
}
sendMessage(STATUS_READ_DATA_DONE, 0);
}
}
private class WriteThread extends Thread {
private ParcelFileDescriptor mFd;
public WriteThread(ParcelFileDescriptor fd) {
super();
mFd = fd;
}
@Override
public void run() {
FileOutputStream fos = new FileOutputStream(mFd.getFileDescriptor());
final byte data_AR[] = new byte[] { (byte) 0xE3, (byte) 0x00,
(byte) 0x00, (byte) 0x2C,
(byte) 0x00, (byte) 0x00,
(byte) 0x50, (byte) 0x79,
(byte) 0x00, (byte) 0x26,
(byte) 0x80, (byte) 0x00, (byte) 0x00, (byte) 0x00,
(byte) 0x80, (byte) 0x00,
(byte) 0x80, (byte) 0x00, (byte) 0x00, (byte) 0x00,
(byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x00,
(byte) 0x80, (byte) 0x00, (byte) 0x00, (byte) 0x00,
(byte) 0x00, (byte) 0x08, //bt add for phone, can be automate in the future
(byte) 0x3C, (byte) 0x5A, (byte) 0x37, (byte) 0xFF,
(byte) 0xFE, (byte) 0x95, (byte) 0xEE, (byte) 0xE3,
(byte) 0x00, (byte) 0x00,
(byte) 0x00, (byte) 0x00,
(byte) 0x00, (byte) 0x00,
(byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x00};
final byte data_DR[] = new byte[] { (byte) 0xE7, (byte) 0x00,
(byte) 0x00, (byte) 0x12,
(byte) 0x00, (byte) 0x10,
(byte) invoke[0], (byte) invoke[1],
(byte) 0x02, (byte) 0x01,
(byte) 0x00, (byte) 0x0A,
(byte) 0x00, (byte) 0x00,
(byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x00,
(byte) 0x0D, (byte) 0x1D,
(byte) 0x00, (byte) 0x00 };
final byte get_MDS[] = new byte[] { (byte) 0xE7, (byte) 0x00,
(byte) 0x00, (byte) 0x0E,
(byte) 0x00, (byte) 0x0C,
(byte) 0x00, (byte) 0x24,
(byte) 0x01, (byte) 0x03,
(byte) 0x00, (byte) 0x06,
(byte) 0x00, (byte) 0x00,
(byte) 0x00, (byte) 0x00,
(byte) 0x00, (byte) 0x00 };
final byte data_RR[] = new byte[] { (byte) 0xE5, (byte) 0x00,
(byte) 0x00, (byte) 0x02,
(byte) 0x00, (byte) 0x00 };
final byte data_RRQ[] = new byte[] { (byte) 0xE4, (byte) 0x00,
(byte) 0x00, (byte) 0x02,
(byte) 0x00, (byte) 0x00 };
final byte data_ABORT[] = new byte[] { (byte) 0xE6, (byte) 0x00,
(byte) 0x00, (byte) 0x02,
(byte) 0x00, (byte) 0x00 };
try {
Log.i(TAG, String.valueOf(count));
if (count == 1)
{
fos.write(data_AR);
Log.i(TAG, "Association Responded!");
}
else if (count == 2)
{
fos.write(get_MDS);
Log.i(TAG, "Get MDS object attributes!");
}
else if (count == 3)
{
fos.write(data_DR);
Log.i(TAG, "Data Responsed!");
}
else if (count == 4)
{
fos.write(data_RR);
Log.i(TAG, "Data Released!");
}
} catch(IOException ioe) {}
}
数据的十六进制表示如下。我相信这些数据包含血压值的值，但可能是错误的。我相信这是唯一的原因是因为在上面链接的 PDF 中，数据将以十六进制值 e7 开头。
03-23 20:14:44.186: I/BluetoothHDPService(23652):e70000da00d80024020300d20000000a00cc0928002000104f4d524f4e204845414c544843415245000c48454d2d373038312d4954000984000a0008002209225835c3280a5a000800010004100700010a4400024000092d00360002003200010001001653455249414c5f4e554d4245523a200000000000004100050001001046575f5245564953494f4e3a203130310914000400005dc00a4b0016000200120201000801000001000200070202000200000a450010c0101f00ffffffff00640000000000000a550008000100040a620006098700082010010100013600000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000
最佳答案
我设法解决了这个问题。我遇到的主要问题是我只读了一个血压读数然后一直按上传。这确实会上传一些关于显示器的信息，但不包括血压读数。知道这一点后，我还有许多其他较小的错误需要解决，但没有什么太复杂的。最终工作服务的代码如下。
public class BluetoothHDPService extends Service {
private static final String TAG = "BluetoothHDPService";
public static final int RESULT_OK = 0;
public static final int RESULT_FAIL = -1;
// Status codes sent back to the UI client.
// Application registration complete.
public static final int STATUS_HEALTH_APP_REG = 100;
// Application unregistration complete.
public static final int STATUS_HEALTH_APP_UNREG = 101;
// Channel creation complete.
public static final int STATUS_CREATE_CHANNEL = 102;
// Channel destroy complete.
public static final int STATUS_DESTROY_CHANNEL = 103;
// Reading data from Bluetooth HDP device.
public static final int STATUS_READ_DATA = 104;
// Done with reading data.
public static final int STATUS_READ_DATA_DONE = 105;
// Message codes received from the UI client.
// Register client with this service.
public static final int MSG_REG_CLIENT = 200;
// Unregister client from this service.
public static final int MSG_UNREG_CLIENT = 201;
// Register health application.
public static final int MSG_REG_HEALTH_APP = 300;
// Unregister health application.
public static final int MSG_UNREG_HEALTH_APP = 301;
// Connect channel.
public static final int MSG_CONNECT_CHANNEL = 400;
// Disconnect channel.
public static final int MSG_DISCONNECT_CHANNEL = 401;
public static final int RECEIVED_SYS = 901;
public static final int RECEIVED_DIA = 902;
public static final int RECEIVED_PUL = 903;
private int count;
private byte[] invoke = {0x00, 0x00};
private BluetoothHealthAppConfiguration mHealthAppConfig;
private BluetoothAdapter mBluetoothAdapter;
private BluetoothHealth mBluetoothHealth;
private BluetoothDevice mDevice;
private int mChannelId;
private Messenger mClient;
// Handles events sent by {@link HealthHDPActivity}.
@SuppressLint("HandlerLeak")
private class IncomingHandler extends Handler {
@Override
public void handleMessage(Message msg) {
switch (msg.what) {
// Register UI client to this service so the client can receive messages.
case MSG_REG_CLIENT:
Log.d(TAG, "Activity client registered");
mClient = msg.replyTo;
break;
// Unregister UI client from this service.
case MSG_UNREG_CLIENT:
mClient = null;
break;
// Register health application.
case MSG_REG_HEALTH_APP:
registerApp(msg.arg1);
break;
// Unregister health application.
case MSG_UNREG_HEALTH_APP:
unregisterApp();
break;
// Connect channel.
case MSG_CONNECT_CHANNEL:
mDevice = (BluetoothDevice) msg.obj;
connectChannel();
break;
// Disconnect channel.
case MSG_DISCONNECT_CHANNEL:
mDevice = (BluetoothDevice) msg.obj;
disconnectChannel();
break;
default:
super.handleMessage(msg);
}
}
}
final Messenger mMessenger = new Messenger(new IncomingHandler());
/**
* Make sure Bluetooth and health profile are available on the Android device. Stop service
* if they are not available.
*/
@SuppressLint("ShowToast")
@Override
public void onCreate() {
super.onCreate();
Log.e("TEST", "HDPService Created");
mBluetoothAdapter = BluetoothAdapter.getDefaultAdapter();
if (mBluetoothAdapter == null || !mBluetoothAdapter.isEnabled()) {
// Bluetooth adapter isn't available. The client of the service is supposed to
// verify that it is available and activate before invoking this service.
stopSelf();
return;
}
if (!mBluetoothAdapter.getProfileProxy(this, mBluetoothServiceListener,
BluetoothProfile.HEALTH)) {
Toast.makeText(this, "bluetooth_health_profile_not_available",
Toast.LENGTH_LONG);
stopSelf();
return;
}
}
@Override
public int onStartCommand(Intent intent, int flags, int startId) {
Log.d(TAG, "BluetoothHDPService is running.");
return START_STICKY;
}
@Override
public IBinder onBind(Intent intent) {
return mMessenger.getBinder();
};
// Register health application through the Bluetooth Health API.
private void registerApp(int dataType) {
Log.e(TAG, "registerApp()");
mBluetoothHealth.registerSinkAppConfiguration(TAG, dataType, mHealthCallback);
}
// Unregister health application through the Bluetooth Health API.
private void unregisterApp() {
Log.e(TAG, "unregisterApp()");
mBluetoothHealth.unregisterAppConfiguration(mHealthAppConfig);
}
// Connect channel through the Bluetooth Health API.
private void connectChannel() {
Log.i(TAG, "connectChannel()");
mBluetoothHealth.connectChannelToSource(mDevice, mHealthAppConfig);
}
// Disconnect channel through the Bluetooth Health API.
private void disconnectChannel() {
Log.i(TAG, "disconnectChannel()");
mBluetoothHealth.disconnectChannel(mDevice, mHealthAppConfig, mChannelId);
}
// Callbacks to handle connection set up and disconnection clean up.
private final BluetoothProfile.ServiceListener mBluetoothServiceListener =
new BluetoothProfile.ServiceListener() {
public void onServiceConnected(int profile, BluetoothProfile proxy) {
if (profile == BluetoothProfile.HEALTH) {
mBluetoothHealth = (BluetoothHealth) proxy;
if (Log.isLoggable(TAG, Log.DEBUG))
Log.d(TAG, "onServiceConnected to profile: " + profile);
}
}
public void onServiceDisconnected(int profile) {
if (profile == BluetoothProfile.HEALTH) {
mBluetoothHealth = null;
}
}
};
private final BluetoothHealthCallback mHealthCallback = new BluetoothHealthCallback() {
// Callback to handle application registration and unregistration events. The service
// passes the status back to the UI client.
public void onHealthAppConfigurationStatusChange(BluetoothHealthAppConfiguration config,
int status) {
if (status == BluetoothHealth.APP_CONFIG_REGISTRATION_FAILURE) {
mHealthAppConfig = null;
sendMessage(STATUS_HEALTH_APP_REG, RESULT_FAIL);
} else if (status == BluetoothHealth.APP_CONFIG_REGISTRATION_SUCCESS) {
mHealthAppConfig = config;
sendMessage(STATUS_HEALTH_APP_REG, RESULT_OK);
} else if (status == BluetoothHealth.APP_CONFIG_UNREGISTRATION_FAILURE ||
status == BluetoothHealth.APP_CONFIG_UNREGISTRATION_SUCCESS) {
sendMessage(STATUS_HEALTH_APP_UNREG,
status == BluetoothHealth.APP_CONFIG_UNREGISTRATION_SUCCESS ?
RESULT_OK : RESULT_FAIL);
}
}
// Callback to handle channel connection state changes.
// Note that the logic of the state machine may need to be modified based on the HDP device.
// When the HDP device is connected, the received file descriptor is passed to the
// ReadThread to read the content.
public void onHealthChannelStateChange(BluetoothHealthAppConfiguration config,
BluetoothDevice device, int prevState, int newState, ParcelFileDescriptor fd,
int channelId) {
Log.e("Read Thread", "Start If Statements");
Log.e("Read Thread", "prevState: " + prevState);
Log.e("Read Thread", "newState: " + newState);
if (Log.isLoggable(TAG, Log.DEBUG))
Log.d(TAG, String.format("prevState\t%d ----------> newState\t%d",
prevState, newState));
// if (prevState != BluetoothHealth.STATE_CHANNEL_CONNECTED &&
// newState == BluetoothHealth.STATE_CHANNEL_CONNECTED) {
if (prevState == BluetoothHealth.STATE_CHANNEL_DISCONNECTED &&
newState == BluetoothHealth.STATE_CHANNEL_CONNECTED) {
if (config.equals(mHealthAppConfig)) {
mChannelId = channelId;
sendMessage(STATUS_CREATE_CHANNEL, RESULT_OK);
Log.e("Read Thread", "Read Start 1");
(new ReadThread(fd)).start();
} else {
Log.e("Read Thread", "Status Create Channel Fail 1");
sendMessage(STATUS_CREATE_CHANNEL, RESULT_FAIL);
}
} else if (prevState == BluetoothHealth.STATE_CHANNEL_CONNECTING &&
newState == BluetoothHealth.STATE_CHANNEL_DISCONNECTED) {
sendMessage(STATUS_CREATE_CHANNEL, RESULT_FAIL);
Log.e("Read Thread", "Status Create Channel Fail 2");
} else if (newState == BluetoothHealth.STATE_CHANNEL_DISCONNECTED) {
if (config.equals(mHealthAppConfig)) {
sendMessage(STATUS_DESTROY_CHANNEL, RESULT_OK);
Log.e("Read Thread", "Status Disconnect OK");
} else {
sendMessage(STATUS_DESTROY_CHANNEL, RESULT_FAIL);
Log.e("Read Thread", "Status Disconnect FAIL");
}
}else if (prevState == BluetoothHealth.STATE_CHANNEL_CONNECTING && newState == BluetoothHealth.STATE_CHANNEL_CONNECTED) {
if (config.equals(mHealthAppConfig)) {
mChannelId = channelId;
sendMessage(STATUS_CREATE_CHANNEL, RESULT_OK);
Log.e("Read Thread", "Read Start 2");
(new ReadThread(fd)).start();
} else {
sendMessage(STATUS_CREATE_CHANNEL, RESULT_FAIL);
Log.e("Read Thread", "Status Create Channel Fail 3");
}
}
}
};
// Sends an update message to registered UI client.
private void sendMessage(int what, int value) {
if (mClient == null) {
Log.d(TAG, "No clients registered.");
return;
}
try {
mClient.send(Message.obtain(null, what, value, 0));
} catch (RemoteException e) {
// Unable to reach client.
e.printStackTrace();
}
}
public String byte2hex(byte[] b){
// String Buffer can be used instead
String hs = "";
String stmp = "";
for (int n = 0; n < b.length; n++){
stmp = (java.lang.Integer.toHexString(b[n] & 0XFF));
if (stmp.length() == 1){
hs = hs + "0" + stmp;
}
else{
hs = hs + stmp;
}
if (n < b.length - 1){
hs = hs + "";
}
}
return hs;
}
public static int byteToUnsignedInt(byte b) {
return 0x00 << 24 | b & 0xff;
}
public static int toInt(byte[] bytes) {
int ret = 0;
for (int i=0; i<4 && i<bytes.length; i++) {
ret <<= 8;
ret |= (int)bytes[i] & 0xFF;
}
return ret;
}
// Thread to read incoming data received from the HDP device. This sample application merely
// reads the raw byte from the incoming file descriptor. The data should be interpreted using
// a health manager which implements the IEEE 11073-xxxxx specifications.
private class ReadThread extends Thread {
private ParcelFileDescriptor mFd;
public ReadThread(ParcelFileDescriptor fd) {
super();
mFd = fd;
}
@Override
public void run() {
Log.e("TEST", "Read Data 1");
FileInputStream fis = new FileInputStream(mFd.getFileDescriptor());
final byte data[] = new byte[200];
Log.i(TAG, "Read Data 2");
try {
while(fis.read(data) > -1) {
// At this point, the application can pass the raw data to a parser that
// has implemented the IEEE 11073-xxxxx specifications. Instead, this sample
// simply indicates that some data has been received.
Log.i(TAG, "INBOUND");
String test = byte2hex(data);
Log.i(TAG, test);
if (data[0] != (byte) 0x00)
{
if(data[0] == (byte) 0xE2){
Log.i(TAG, "E2 - Association Request");
count = 1;
(new WriteThread(mFd)).start();
try {
sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
count = 2;
(new WriteThread(mFd)).start();
}
else if (data[0] == (byte)0xE7){
Log.i(TAG, "E7 - Data Given");
if(data[3] != (byte)0xda){
invoke[0] = data[6];
invoke[1] = data[7];
Log.i(TAG, "E7 - Reading?");
ByteBuffer sys = ByteBuffer.allocate(2);
sys.order(ByteOrder.LITTLE_ENDIAN);
sys.put(data[45]);
sys.put(data[46]);
short sysVal = sys.getShort(0);
Log.i(TAG, " Sys - "+sysVal);
ByteBuffer dia = ByteBuffer.allocate(2);
dia.order(ByteOrder.LITTLE_ENDIAN);
dia.put(data[47]);
dia.put(data[48]);
short diaVal = dia.getShort(0);
Log.i(TAG, " Dia - "+diaVal);
sendMessage(9919, diaVal);
sendMessage(9920, sysVal);
for(int i=0; i<(data.length-2); i++){
ByteBuffer bb = ByteBuffer.allocate(2);
bb.order(ByteOrder.LITTLE_ENDIAN);
bb.put(data[i]);
bb.put(data[i+1]);
short shortVal = bb.getShort(0);
Log.i(TAG, i+" Short Val - "+shortVal);
}
count = 3;
//set invoke id so get correct response
(new WriteThread(mFd)).start();
}
//parse data!!
}
else if (data[0] == (byte) 0xE4)
{
//count = 4;
// (new WriteThread(mFd)).start();
}
//zero out the data
for (int i = 0; i < data.length; i++){
data[i] = (byte) 0x00;
}
}
sendMessage(STATUS_READ_DATA, 0);
}
} catch(IOException ioe) {}
if (mFd != null) {
try {
mFd.close();
} catch (IOException e) { /* Do nothing. */ }
}
sendMessage(STATUS_READ_DATA_DONE, 0);
}
}
private class WriteThread extends Thread {
private ParcelFileDescriptor mFd;
public WriteThread(ParcelFileDescriptor fd) {
super();
mFd = fd;
}
@Override
public void run() {
FileOutputStream fos = new FileOutputStream(mFd.getFileDescriptor());
final byte data_AR[] = new byte[] { (byte) 0xE3, (byte) 0x00,
(byte) 0x00, (byte) 0x2C,
(byte) 0x00, (byte) 0x00,
(byte) 0x50, (byte) 0x79,
(byte) 0x00, (byte) 0x26,
(byte) 0x80, (byte) 0x00, (byte) 0x00, (byte) 0x00,
(byte) 0x80, (byte) 0x00,
(byte) 0x80, (byte) 0x00, (byte) 0x00, (byte) 0x00,
(byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x00,
(byte) 0x80, (byte) 0x00, (byte) 0x00, (byte) 0x00,
(byte) 0x00, (byte) 0x08, //bt add for phone, can be automate in the future
(byte) 0x3C, (byte) 0x5A, (byte) 0x37, (byte) 0xFF,
(byte) 0xFE, (byte) 0x95, (byte) 0xEE, (byte) 0xE3,
(byte) 0x00, (byte) 0x00,
(byte) 0x00, (byte) 0x00,
(byte) 0x00, (byte) 0x00,
(byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x00};
final byte data_DR[] = new byte[] { (byte) 0xE7, (byte) 0x00,
(byte) 0x00, (byte) 0x12,
(byte) 0x00, (byte) 0x10,
(byte) 0x00, (byte) 0x24,
(byte) 0x02, (byte) 0x01,
(byte) 0x00, (byte) 0x0A,
(byte) 0x00, (byte) 0x00,
(byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x00,
(byte) 0x0D, (byte) 0x1D,
(byte) 0x00, (byte) 0x00 };
final byte get_MDS[] = new byte[] { (byte) 0xE7, (byte) 0x00,
(byte) 0x00, (byte) 0x0E,
(byte) 0x00, (byte) 0x0C,
(byte) 0x00, (byte) 0x24,
(byte) 0x01, (byte) 0x03,
(byte) 0x00, (byte) 0x06,
(byte) 0x00, (byte) 0x00,
(byte) 0x00, (byte) 0x00,
(byte) 0x00, (byte) 0x00 };
final byte data_RR[] = new byte[] { (byte) 0xE5, (byte) 0x00,
(byte) 0x00, (byte) 0x02,
(byte) 0x00, (byte) 0x00 };
// final byte data_RRQ[] = new byte[] { (byte) 0xE4, (byte) 0x00,
// (byte) 0x00, (byte) 0x02,
// (byte) 0x00, (byte) 0x00 };
//
// final byte data_ABORT[] = new byte[] { (byte) 0xE6, (byte) 0x00,
// (byte) 0x00, (byte) 0x02,
// (byte) 0x00, (byte) 0x00 };
try {
Log.i(TAG, String.valueOf(count));
if (count == 1)
{
fos.write(data_AR);
Log.i(TAG, "Association Responded!");
}
else if (count == 2)
{
fos.write(get_MDS);
Log.i(TAG, "Get MDS object attributes!");
}
else if (count == 3)
{
fos.write(data_DR);
Log.i(TAG, "Data Responsed!");
}
else if (count == 4)
{
fos.write(data_RR);
Log.i(TAG, "Data Released!");
}
} catch(IOException ioe) {}
}
}
}
关于java - 解析从蓝牙 HDP 设备接收到的原始数据，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/15591637/
25
4
0
我正在使用 HDP 2.5 和 NiFI-1.1.0.2.1.2.0。谁能告诉我如何将 nifi 流从一个 HDP 导出和导入到另一个 HDP 最佳答案 NiFi可以通过模板导出/导入流。您可以将流程
我们有 ambari 集群版本 - 2.5.0.3(有 3 个主节点和 3 个工作节点) 我们正在从 HDP 版本 2.6.0.3 升级到 2.6.4 版本 最后阶段安装失败 出现在 - Finali
我正在使用 10 个节点的 HDP 集群，其中 10 个节点中的一个在几个小时内重新启动，正如 Linux 管理员所建议的那样，我们已经重新部署了该特定节点。该节点由 Zookeeper server
使用 REST API 在 apache atlas 中添加实体之间的关系的正确方法是什么？看着docs对于 REST API，我发现很难说出某些字段的含义，哪些字段是必需的(以及如果不输入会发生什么
我正在研究Hortonworks(Hortonworks数据平台)的后端以及Ambari，用于管理hadoop集群。现在我对这里的后端感到困惑。 HDP后端意味着使用Kerberos设置LDAP /
首先，如果我要问一个明显的问题，我会提前道歉。 我正在尝试公开 Hortonworks HDP docker(版本 2.6.5)端口，以便可以通过网络访问 Ambari UI 和打包的所有功能。我关注
我正在尝试从欧姆龙 708-BT 血压监测仪读取数据，该监测仪已通过 continua 健康联盟认证。我正在关注这个例子 of a Bluetooth HDP App .我设法连接到设备并以字节格式检
我正在经历一个Hadoop集群的部署和管理，我发现，对于这个目的，Ambari是一个非常有用和方便的工具。 现在我想弄清楚 HDP 堆栈的所有许可证是否也允许在生产环境中部署 Hadoop 安装。 有
我碰巧在 CDH 工作了很长时间(大约 1 年)，并计划重新开始。现在我们有 CDH、HDP 和 Hortonwork 被 Cloudera 收购。 HDP 是否正在积极开发中？还是CDH正在积极开发
我正在从RPM在CentOS 6.5 64位上手动安装Hortonworks Data Platform 2.2。在格式化名称节点期间，“抛出”参数不足错误 这些是根据手册的说明: Format an
我刚开始使用nutch，昨天花了钱才弄清楚 如何在我遇到的最新 HDP (2.3.2) vm 上运行 nutch 问题。 直接构建源代码，一切顺利， 但是在本地第一次运行之后，我遇到了 java.la
我使用Hortonworks Data Platform 2.5和Ambari 2.4设置了Hadoop集群。我还通过Ambari UI将Zeppelin服务添加到集群安装中。 由于启用了Kerber
我试图将其他主机添加到运行HDP 2.4的Ambari群集中，并且Metrics Monitor似乎安装不正确，所有其他服务均正常运行。 下面是尝试在其中一台新主机上启动Metrics Monitor
我们执行以下步骤 - (来自 ambari GUI) 管理员 – 堆栈和版本 -> 版本 管理版本 确定 注册版本 注册版本 我选择按钮“HDP-2.6”来添加新版本并浏览 VDF 文件——(VDF
我正在尝试在运行 CentOS 7 操作系统的虚拟机中设置单节点 HDP 安装。 是否可以在没有 Ambari 的情况下进行设置？或者这是一个硬性的先决条件？我正在寻找安装 HDP 3.1。 谢谢!
鉴于Pivotal HD已经停产，并且Pivotal现在建议升级到Hortonworks HDP，因此我试图了解升级过程。由于Pivotal HD使用Ambari作为管理器，因此我们可以使用Horto
我正在使用 gensim 主题建模软件中的 HDP(分层 Dirichilet 过程)包。 Gensim HDP 实现期望用户提前提供主题数量 (T)。 hdpmodel.HdpModel( self
iOS 是否支持 HDP(健康设备配置文件)？有可用的示例吗？ 最佳答案 iOS 不支持蓝牙 2.1 的 HDP。它可以使用蓝牙 4.0 LE (CoreBluetooth) 连接到任何设备，但您实际
我已经创建了 HDP & HDP-UTILS-1.1.0.21 内部存储库映射如下: curl -H "X-Requested-By: ambari" -X PUT -u admin:admin ht
如 this 等几个链接中所述和 this ，我正在尝试清理卸载 Hortonworks 2.2 数据平台。 在 Linux 中天真，我面临着第一步本身的问题 - 删除已安装的 HDP 包。 [roo
我是一名优秀的程序员,十分优秀！