利用Socket与硬件通信（智能家居）

  1  @Override
  2     protected void onCreate(Bundle savedInstanceState) {
  3 
  4         super.onCreate(savedInstanceState);
  5         setContentView(R.layout.activity_main);
  6 
  7         mEditText = (EditText) findViewById(R.id.edittext);
  8         connectButton = (Button) findViewById(R.id.connectbutton);
  9         sendButton = (Button) findViewById(R.id.sendbutton);
 10         mTextView = (TextView) findViewById(R.id.retextview);
 11    
 12 
 13             //连接按钮 
 14           connectButton.setOnClickListener(new View.OnClickListener() {
 15             @Override
 16             public void onClick(View view) {
 17                 new Thread() {
 18                     @Override
 19                     public void run() {
 20                         super.run();
 21                         try {
 22                             clientSocket = new Socket("192.168.23.6", 3000);
 23                             mReceiveThread = new ReceiveThread(clientSocket);
 24                             mReceiveThread.start();
 25                         }catch (IOException e) {
 26                             e.printStackTrace();
 27                         }
 28                     }
 29                 }.start();
 30                 displayToast("连接成功");
 31                 stop = false;
 32             }
 33         });
 34           //发送数据
 35         sendButton.setOnClickListener(new View.OnClickListener() {
 36             @Override
 37             public void onClick(View view) {
 38                 byte[] msgBuffer = null;
 39 
 40                 String text = mEditText.getText().toString();
 41 
 42                 try {
 43                     msgBuffer = text.getBytes("GB2312");
 44                     outStrean = clientSocket.getOutputStream();
 45                     outStrean.write(msgBuffer);
 46                 } catch (IOException e) {
 47                     e.printStackTrace();
 48                 }
 49                 mTextView.setText(text);
 50                 displayToast("发送成功");
 51             }
 52         });
 53 
 54     }
 55 
 56     private void displayToast(String s) {
 57         Toast.makeText(this, s, Toast.LENGTH_SHORT).show();
 58     }
 59 
 60     private class ReceiveThread extends Thread {
 61         private InputStream inStrean = null;
 62         private byte[] buf11 = new byte[1024];
 63         private String str11 = null;
 64 
 65         public ReceiveThread(Socket s) {
 66             try {
 67                 this.inStrean = s.getInputStream();
 68             } catch (IOException e) {
 69                 e.printStackTrace();
 70             }
 71         }
 72 
 73         @Override
 74         public void run() {
 75             super.run();
 76             while (!stop) {
 77                 try {
 78                     this.inStrean.read(buf11);
 79                     str11 = new String(buf11,"GB2312");
 80                     Gson gson = new Gson();
 81                     JsonReader reader = new JsonReader(new StringReader(str11));
 82                     reader.setLenient(true);
 83                     Student student = gson.fromJson(reader,Student.class);
 84 
 85              String name = student.getName();
 86             //    System.out.println(student.toString());
 87                     Message msg = new Message();
 88                     msg.obj = name;
 89                     mHandle.sendMessage(msg);
 90                 } catch (IOException e) {
 91                     e.printStackTrace();
 92                 }
 93             }
 94         }
 95     }
 96 
 97 
 98     @Override
 99     public void onDestroy() {
100         super.onDestroy();
101         if (mReceiveThread != null) {
102             try {
103                 clientSocket.close();
104                 stop = true;
105                 mReceiveThread.interrupt();
106             } catch (IOException e) {
107                 e.printStackTrace();
108             }
109         }
110     }
111 }