Android|Android Socket通信的简单实现 AndroidSocket通信的简单实现

公司要实现一个简单的聊天功能，提前研究一下Socket通信，而公司的服务端功能又没有实现，所以这里就把服务端的功能放到一个界面实现了。
直接上代码：

【Android|Android Socket通信的简单实现】主要代码：

package com.app.socketdemo; import android.annotation.SuppressLint; import android.os.Bundle; import android.os.Handler; import android.os.Message; import android.text.Html; import android.text.TextUtils; import android.view.View; import android.widget.Button; import android.widget.EditText; import android.widget.ScrollView; import android.widget.TextView; import android.widget.Toast; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.InetAddress; import java.net.ServerSocket; import java.net.Socket; import androidx.appcompat.app.AppCompatActivity; import butterknife.BindView; import butterknife.ButterKnife; import butterknife.OnClick; public class MainActivity extends AppCompatActivity {@BindView(R.id.et_ip)EditText etIp; @BindView(R.id.btn_connect)Button btnConnect; @BindView(R.id.tv_receive)TextView tvReceive; @BindView(R.id.tv_content)TextView tvContent; @BindView(R.id.et_input)EditText etInput; @BindView(R.id.btn_send)Button btnSend; @BindView(R.id.sv_content)ScrollView svContent; @BindView(R.id.btn_service)Button btnService; private StringBuffer strMsg = new StringBuffer(); private final int MESSAGE_ERROR = 0; private final int MESSAGE_SUCCEED = 1; private final int MESSAGE_RECEIVE = 2; private Socket sock; private OutputStream outx; private InputStream inx; @Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); ButterKnife.bind(this); //启动服务端new Thread(() -> new Server().startService()).start(); } @OnClick({R.id.btn_connect, R.id.btn_service, R.id.btn_send})public void onViewClicked(View view) {switch (view.getId()) {case R.id.btn_connect://连接服务端String strip = etIp.getText().toString().trim(); if (strip.indexOf(":") >= 0) {//启动连接new Socket_thread(strip).start(); }break; case R.id.btn_service:if (!TextUtils.isEmpty(etInput.getText().toString())) {sendString("服务端：" + etInput.getText().toString().trim()); etInput.setText(""); } else {Toast.makeText(this, "输入不可为空", Toast.LENGTH_SHORT).show(); }break; case R.id.btn_send:if (!TextUtils.isEmpty(etInput.getText().toString())) {sendStrSocket("客户端：" + etInput.getText().toString().trim()); etInput.setText(""); } else {Toast.makeText(this, "输入不可为空", Toast.LENGTH_SHORT).show(); }break; }} /*** 连接服务器*/class Socket_thread extends Thread {private String IP = ""; //ip地址private int PORT = 0; //端口号 public Socket_thread(String strip) {//如: 127.0.0.1:8081String[] stripx = strip.split(":"); this.IP = stripx[0]; this.PORT = Integer.parseInt(stripx[1]); } @Overridepublic void run() {try {disSocket(); //连接服务器，此处会一直处于阻塞，直到连接成功sock = new Socket(this.IP, this.PORT); //阻塞停止，表示连接成功setMessage("连接成功", MESSAGE_SUCCEED); } catch (Exception e) {setMessage("连接服务器时异常", MESSAGE_ERROR); e.printStackTrace(); return; }try {//获取到输入输出流outx = sock.getOutputStream(); inx = sock.getInputStream(); } catch (Exception e) {setMessage("获取输入输出流异常", MESSAGE_ERROR); e.printStackTrace(); return; }new Inx().start(); }} /*** 循环接收数据*/class Inx extends Thread {@Overridepublic void run() {while (true) {byte[] bu = new byte[1024]; try {int conut = inx.read(bu); //设备重启，异常将会一直停留在这if (conut == -1) {setMessage("服务器断开", MESSAGE_ERROR); disSocket(); return; } String strread = new String(bu, "GBK").trim(); setMessage(strread, MESSAGE_RECEIVE); } catch (IOException e) {System.out.println(e); }}}} /*** 断开连接*/private void disSocket() {if (sock != null) {try {outx.close(); inx.close(); sock.close(); sock = null; } catch (Exception e) {setMessage("断开连接时发生错误", MESSAGE_ERROR); }}} @SuppressLint("HandlerLeak")private Handler handler = new Handler() {@Overridepublic void handleMessage(Message msg) {switch (msg.arg1) {case MESSAGE_ERROR:disSocket(); strMsg.append(msg.obj + "
"); tvContent.setText(Html.fromHtml(strMsg.toString())); break; case MESSAGE_SUCCEED:strMsg.append(msg.obj + "
"); tvContent.setText(Html.fromHtml(strMsg.toString())); break; case MESSAGE_RECEIVE://收到数据strMsg.append(msg.obj); if (!strMsg.toString().substring(strMsg.length() - 4, strMsg.length()).equals("
")) {strMsg.append("
"); }tvContent.setText(Html.fromHtml(strMsg.toString())); svContent.fullScroll(ScrollView.FOCUS_DOWN); break; default:break; }}}; /*** 发送消息*/private void sendStrSocket(final String senddata) {new Thread(new Runnable() {@Overridepublic void run() {try {String str = "" + senddata + ""; outx.write(str.getBytes("gbk")); //"utf-8"} catch (Exception e) {setMessage("数据发送异常", MESSAGE_ERROR); }}}).start(); } /*** 消息处理*/private void setMessage(String obj, int arg1){Message message = new Message(); message.arg1 = arg1; message.obj = obj; handler.sendMessage(message); } /*************************************************************服务端(用于测试)**********************************************************************/private String msg = ""; public class Server {ServerSocket serverSocket = null; public final int port = 8081; public Server() {//输出服务器的IP地址try {InetAddress addr = InetAddress.getLocalHost(); serverSocket = new ServerSocket(port); } catch (IOException e) {e.printStackTrace(); }} public void startService() {try {while (true) {Socket socket = null; socket = serverSocket.accept(); //等待一个客户端的连接，在连接之前，此方法是阻塞的new ConnectThread(socket).start(); new ConnectThread1(socket).start(); }} catch (IOException e) {e.printStackTrace(); } } /*** 向客户端发送信息*/class ConnectThread extends Thread {Socket socket = null; public ConnectThread(Socket socket) {super(); this.socket = socket; } @Overridepublic void run() {try {DataOutputStream out = new DataOutputStream(socket.getOutputStream()); while (true) {Thread.sleep(1000); if (!TextUtils.isEmpty(msg)) {String str = "" + msg + ""; out.write(str.getBytes("gbk")); out.flush(); msg = ""; }}} catch (IOException e) {e.printStackTrace(); } catch (InterruptedException e) {e.printStackTrace(); }}} /*** 接收客户端信息*/class ConnectThread1 extends Thread {Socket socket = null; public ConnectThread1(Socket socket) {super(); this.socket = socket; } @Overridepublic void run() {try {DataInputStream inp = new DataInputStream(socket.getInputStream()); while (true) {byte[] bu = new byte[1024]; int conut = inp.read(bu); //设备重启，异常将会一直停留在这if (conut == -1) {setMessage("服务器断开", MESSAGE_ERROR); return; }String strread = new String(bu, "GBK").trim(); setMessage(strread, MESSAGE_RECEIVE); }} catch (IOException e) {e.printStackTrace(); }}}} private void sendString(String str) {msg = str; }}

运行效果：