Android基于局域网socket通信

package com.xiaoxiao9575.socketapplication; import android.annotation.SuppressLint; import android.os.AsyncTask; import android.os.Handler; import android.os.Message; import android.support.v7.app.AppCompatActivity; import android.os.Bundle; import android.util.Log; import android.view.View; import android.widget.Button; import android.widget.EditText; import android.widget.TextView; import android.widget.Toast; import java.io.BufferedReader; import java.io.BufferedWriter; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStream; import java.io.OutputStreamWriter; import java.net.InetSocketAddress; import java.net.Socket; import java.net.SocketTimeoutException; public class ClientActivity extends AppCompatActivity { private EditText et_ip; private EditText et_msg; private TextView tv_send; private TextView tv_confirm; private Socket mSocket; private OutputStream mOutStream; private InputStream mInStream; private SocketConnectThread socketConnectThread; private StringBuffer sb = new StringBuffer(); @SuppressLint("HandlerLeak") public Handler handler = new Handler(){ @Override public void handleMessage(Message msg) { super.handleMessage(msg); if (msg.what == 1){ Bundle data = msg.getData(); sb.append(data.getString("msg")); sb.append("\n"); tv_msg.setText(sb.toString()); } } }; private TextView tv_msg; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_client); socketConnectThread = new SocketConnectThread(); initView(); setListener(); } private void initView() { et_ip = (EditText) findViewById(R.id.et_ip); et_msg = (EditText) findViewById(R.id.et_msg); tv_send = (TextView) findViewById(R.id.tv_send); tv_confirm = (TextView) findViewById(R.id.tv_confirm); tv_msg = (TextView) findViewById(R.id.tv_msg); } private void setListener() { tv_send.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View v) { send(et_msg.getText().toString()); } }); tv_confirm.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View v) { socketConnectThread.start(); } }); } class SocketConnectThread extends Thread{ public void run(){ Log.e("info", "run: ============线程启动" ); try { //指定ip地址和端口号 mSocket = new Socket(et_ip.getText().toString(), 1989); if(mSocket != null){ //获取输出流、输入流 mOutStream = mSocket.getOutputStream(); mInStream = mSocket.getInputStream(); }else { Log.e("info", "run: =========scoket==null"); } } catch (Exception e) { e.printStackTrace(); return; } Log.e("info","connect success========================================"); startReader(mSocket); } } public void send(final String str) { if (str.length() == 0){ return; } new Thread() { @Override public void run() { try { // socket.getInputStream() DataOutputStream writer = new DataOutputStream(mSocket.getOutputStream()); writer.writeUTF(str); // 写一个UTF-8的信息 System.out.println("发送消息"); } catch (IOException e) { e.printStackTrace(); } } }.start(); } /** * 从参数的Socket里获取最新的消息 */ private void startReader(final Socket socket) { new Thread(){ @Override public void run() { DataInputStream reader; try { // 获取读取流 reader = new DataInputStream(socket.getInputStream()); while (true) { System.out.println("*等待客户端输入*"); // 读取数据 String msg = reader.readUTF(); System.out.println("获取到客户端的信息：=" + msg); Message message = new Message(); message.what = 1; Bundle bundle = new Bundle(); bundle.putString("msg", msg); message.setData(bundle); handler.sendMessage(message); } } catch (IOException e) { e.printStackTrace(); } } }.start(); } }