- byte[] buffer = new byte[1024];
- int bytes;
- InputStream in = null;
- try {
- in = mClientSocket.getInputStream();
- while (true) {
- if ((bytes = in.read(buffer)) > 0) {
- byte[] buf_data = new byte[bytes];
- for (int i = 0; i < bytes; i++) {
- buf_data[i] = buffer[i];
- int j = buffer[i];
- j = buffer[i] & 0xff;
- String str = Integer.toHexString(j);
- if ("ff".equals(str)) {
- Message msg = Message.obtain(null, MSG_UPDATE_LOG);
- msg.obj = "台灯打开";
- mHandler.sendMessage(msg);
- } else if ("0".equals(str)) {//注意不能用00,因为0x00实际的值是0
- Message msg = Message.obtain(null, MSG_UPDATE_LOG);
- msg.obj = "台灯关闭";
- mHandler.sendMessage(msg);
- } else {
- Message msg = Message.obtain(null, MSG_UPDATE_LOG);
- msg.obj = "err...";
- mHandler.sendMessage(msg);
- }
- }
- }
- }
- } catch (IOException e) {
- e.printStackTrace();
- Message msg = Message.obtain(null, MSG_UPDATE_LOG);
- msg.obj = "连接数据失败";
- mHandler.sendMessage(msg);
- } finally {
- if (in != null)
- try {
- in.close();
- } catch (IOException e) {
- e.printStackTrace();
- }
- }
|