简介本资源是一套基于Socket通信实现的Android端仿微信即时通讯软件完整源码面向Android开发初学者与中级工程师适用于网络编程、客户端-服务器架构设计及IM应用开发学习场景。压缩包共797个文件包含76个Java核心逻辑代码、78个XML布局与配置文件、368张UI资源PNG图、133个编译后Class字节码以及服务端相关SQL脚本、技术文档、消息类型定义、组件缩写说明等配套材料整体体积10.64MB结构清晰便于分层理解客户端通信机制与服务端协同逻辑。已有288人下载学习读者可直接运行调试Client.apk与服务端程序掌握长连接管理、消息收发流程、UI交互设计及常见Bug修复记录同时获取命名规范、生命周期控制、消息类型建模等工程实践参考。1. 这不是又一个“仿微信”Demo而是一套可调试、可扩展的Android端到端Socket通信最小可行系统很多开发者下载“仿微信源码”后发现UI能跑消息发不出去服务端启动了客户端连不上Logcat里满屏IOException: socket failed: ECONNREFUSED却不知从哪改起。这套Android仿微信聊天软件Socket实现源码包含服务端.zip真正价值在于——它剥离了IM SDK黑盒封装用原生Java Socket非WebSocket、非Netty封装层直连TCP长连接完整呈现了客户端心跳保活、服务端多线程连接管理、消息协议编码/解码、离线消息暂存逻辑四个硬核模块。适合Android中级开发者2~5年经验用于理解即时通讯底层链路也适合作为毕业设计或企业内部轻量级协作工具的技术基座。它不追求UI还原度但每个.java文件都标注了关键通信状态流转节点服务端用纯JavaServerSocket实现无需额外部署Tomcat或Spring Boot容器javac java两步即可验证通路。2. 为什么选原生Socket而非OkHttp/WebSocket从协议分层看通信可靠性设计2.1 即时通讯场景下TCP长连接的核心诉求与Socket的不可替代性在移动端IM开发中高频小包、低延迟、强连接状态感知是刚需。HTTP短连接每次交互需三次握手TLS协商微信类应用每秒可能产生数十次状态同步输入状态、已读回执、Typing提示若走HTTP轮询或长轮询网络开销和服务器负载呈指数级增长。而原生Socket直接工作在传输层客户端与服务端建立一次TCP连接后可复用该连接发送任意次数消息且通过setSoTimeout()、isClosed()、isConnected()等API实时感知链路健康度。本项目服务端ChatServer.java中while (true)循环内serverSocket.accept()阻塞等待新连接正是对OSI模型第四层传输层能力的直接调用——这比任何上层封装如OkHttp的WebSocket更贴近网络本质也更利于排查EADDRINUSE、ECONNRESET等底层错误。提示项目未使用Netty或Mina等NIO框架是因为其目标是教学可读性。对于生产环境高并发场景应升级为基于Selector的NIO实现但本源码的Thread per Connection模型恰好暴露了传统BIO的瓶颈点为后续优化提供明确靶点。2.2 消息协议设计用固定头变长体解决粘包与拆包问题Socket传输的是字节流而非消息边界清晰的数据包。若客户端连续发送hello和world服务端InputStream.read(buffer)可能一次性读到helloworld粘包也可能分两次读到hel和loworld拆包。本项目采用经典TLVType-Length-Value结构// ClientMessage.java 中定义协议头 public class ClientMessage { public static final int MSG_TYPE_TEXT 1; public static final int MSG_TYPE_HEARTBEAT 2; private int type; // 4字节消息类型 private int length; // 4字节后续内容长度不含头 private String content; // 变长UTF-8字符串 // 序列化为byte[][type:int][length:int][content:bytes] public byte[] toBytes() { byte[] contentBytes content.getBytes(StandardCharsets.UTF_8); ByteBuffer buffer ByteBuffer.allocate(8 contentBytes.length); buffer.putInt(type); buffer.putInt(contentBytes.length); buffer.put(contentBytes); return buffer.array(); } }服务端ChatHandler.java中解析逻辑严格按此结构读取// 读取固定8字节头部 byte[] header new byte[8]; int read inputStream.read(header); if (read ! 8) throw new IOException(Header incomplete); ByteBuffer headerBuffer ByteBuffer.wrap(header); int type headerBuffer.getInt(); int length headerBuffer.getInt(); // 再读取length字节内容 byte[] contentBytes new byte[length]; read inputStream.read(contentBytes); if (read ! length) throw new IOException(Content incomplete);2.2.1 关键参数说明与调试技巧参数位置作用调试建议type协议头前4字节区分文本消息、心跳、登录请求等语义在Wireshark中过滤tcp.port 8080 tcp.len 8右键Follow → TCP Stream查看原始字节验证前4字节是否为00 00 00 01MSG_TYPE_TEXTlength协议头后4字节告知接收方后续内容字节数避免无限读取若服务端卡死在inputStream.read(contentBytes)检查客户端是否正确写入了content.length而非content.length()1content头部后变长部分UTF-8编码的消息体支持中文Android端发送含中文消息时确保content.getBytes(StandardCharsets.UTF_8)与服务端new String(bytes, StandardCharsets.UTF_8)编码一致否则出现乱码2.3 客户端连接管理从Activity生命周期到Socket状态机的映射Android Activity可能因屏幕旋转、内存回收被销毁重建但Socket连接必须保持存活。本项目在ChatActivity.java中将Socket声明为static并配合Application级别生命周期管理public class ChatApplication extends Application { private static Socket clientSocket; private static PrintWriter out; private static BufferedReader in; public static void connect(String host, int port) throws IOException { if (clientSocket null || !clientSocket.isConnected() || clientSocket.isClosed()) { clientSocket new Socket(host, port); out new PrintWriter(clientSocket.getOutputStream(), true); in new BufferedReader(new InputStreamReader(clientSocket.getInputStream())); } } // 提供静态方法供Activity调用 public static void sendMessage(String msg) { if (out ! null) out.println(msg); // 注意此处简化实际应走ClientMessage.toBytes() } }注意static Socket在进程被杀后会失效此设计仅适用于前台活跃场景。生产环境需改用ServiceForeground Service保活并监听ConnectivityManager.CONNECTIVITY_ACTION广播处理网络切换。3. 服务端核心实现多线程连接池与内存级消息路由3.1 ServerSocket基础架构与连接拒绝策略服务端入口ChatServer.java启动流程极简public class ChatServer { private static final int PORT 8080; private static final ListChatHandler clients Collections.synchronizedList(new ArrayList()); public static void main(String[] args) throws IOException { ServerSocket serverSocket new ServerSocket(PORT); System.out.println(Chat server started on port PORT); while (true) { Socket clientSocket serverSocket.accept(); // 阻塞等待连接 ChatHandler handler new ChatHandler(clientSocket); Thread thread new Thread(handler); thread.start(); clients.add(handler); } } }此处ServerSocket(PORT)隐含关键配置若端口被占用抛出java.net.BindException: Address already in use。常见原因包括其他Java进程占用了8080端口lsof -i :8080或netstat -ano | findstr :8080上次服务异常退出Socket处于TIME_WAIT状态Linux默认60秒需等待或改用SO_REUSEADDRWindows防火墙拦截入站连接需在防火墙设置中允许Java SE Binary3.2 ChatHandler线程封装单连接全生命周期每个ChatHandler实例对应一个客户端连接其run()方法实现完整状态机public class ChatHandler implements Runnable { private Socket socket; private BufferedReader in; private PrintWriter out; private String clientId; Override public void run() { try { in new BufferedReader(new InputStreamReader(socket.getInputStream())); out new PrintWriter(socket.getOutputStream(), true); // 1. 登录握手读取首行作为clientId clientId in.readLine(); if (clientId null) return; System.out.println(Client clientId connected); // 2. 主循环持续读取消息并广播 String inputLine; while ((inputLine in.readLine()) ! null) { System.out.println(Received from clientId : inputLine); broadcast(clientId, inputLine); // 广播给其他所有客户端 } } catch (IOException e) { System.err.println(Client clientId disconnected: e.getMessage()); } finally { cleanup(); } } private void broadcast(String sender, String message) { synchronized (clients) { for (ChatHandler client : clients) { if (!client.clientId.equals(sender) client.out ! null) { client.out.println(sender : message); } } } } private void cleanup() { clients.remove(this); try { if (socket ! null) socket.close(); } catch (IOException e) { e.printStackTrace(); } } }3.2.1 线程安全关键点分析场景风险本项目解决方案生产环境升级建议多线程并发修改clients列表ConcurrentModificationException使用Collections.synchronizedList()包装改用CopyOnWriteArrayList避免迭代时加锁广播时某客户端Socket已断开NullPointerExceptiononclient.outif (client.out ! null)空值检查增加client.socket.isClosed()双重校验客户端发送超长消息导致readLine()阻塞OOM或线程饥饿无显式限制依赖TCP缓冲区在BufferedReader构造时指定new InputStreamReader(socket.getInputStream(), StandardCharsets.UTF_8, 8192)3.3 消息广播机制的局限性与离线消息改造路径当前广播逻辑broadcast()仅向在线客户端推送若用户A发送消息时用户B离线则B永远收不到。要支持离线消息需引入内存级队列// 新增离线消息存储生产环境应替换为Redis或数据库 private static final MapString, QueueString offlineMessages new ConcurrentHashMap(); // 在broadcast中若目标client不在线则存入队列 if (!client.clientId.equals(sender) client.out ! null) { client.out.println(sender : message); } else { offlineMessages.computeIfAbsent(client.clientId, k - new ConcurrentLinkedQueue()) .add(sender : message); } // 客户端重连时在ChatHandler.run()登录后立即推送 ListString pending offlineMessages.remove(clientId); if (pending ! null) { for (String msg : pending) { out.println([OFFLINE] msg); } }4. Android客户端实战从Android Studio编译到真机调试的完整链路4.1 环境准备与APK构建项目提供Client.apk但为深入理解需自行编译。使用Android Studio打开app/目录需确认build.gradle中compileSdkVersion与本地SDK匹配android { compileSdkVersion 33 // 根据你安装的SDK版本调整 defaultConfig { applicationId com.example.chatclient minSdkVersion 21 // Socket通信最低要求Android 5.0 targetSdkVersion 33 } }关键依赖仅需androidx.appcompat:appcompat无第三方网络库dependencies { implementation androidx.appcompat:appcompat:1.6.1 implementation com.google.android.material:material:1.9.0 }编译命令终端进入项目根目录# 生成debug APK ./gradlew assembleDebug # APK路径app/build/outputs/apk/debug/app-debug.apk提示若遇到Failed to install app-debug.apk: Failure [INSTALL_FAILED_USER_RESTRICTED]需在手机开发者选项中关闭“USB调试安全设置”。4.2 权限配置与网络访问白名单Android 9API 28以上默认禁止HTTP明文流量。服务端使用http://地址如192.168.1.100:8080需在AndroidManifest.xml中添加application android:usesCleartextTraffictrue ... uses-permission android:nameandroid.permission.INTERNET / uses-permission android:nameandroid.permission.ACCESS_NETWORK_STATE / /application对于Android 10还需在res/xml/network_security_config.xml中显式允许?xml version1.0 encodingutf-8? network-security-config domain-config domain includeSubdomainstrue192.168.1.100/domain cleartextTrafficPermittedtrue / /domain-config /network-security-config并在AndroidManifest.xml中引用application android:networkSecurityConfigxml/network_security_config ... 4.3 真机调试关键步骤与典型错误定位步骤1确认服务端IP可达在Android设备浏览器中访问http://192.168.1.100:8080服务端所在电脑局域网IP若返回Connection refused说明服务端未运行或防火墙拦截若超时检查手机与电脑是否在同一WiFi子网。步骤2抓包验证Socket连接使用Packet CapturePlay Store应用或Wireshark电脑端捕获设备流量过滤条件tcp.port 8080正常流程SYN → SYN-ACK → ACK → [PSH, ACK]发送clientId→[PSH, ACK]发送消息异常信号仅出现SYN无响应 → 服务端未监听出现RST→ 服务端主动拒绝步骤3Logcat关键日志解读// 成功连接 D/ChatActivity: Connected to 192.168.1.100:8080 // 发送失败服务端宕机 W/System.err: java.net.ConnectException: Connection refused // 接收消息需在ChatActivity中添加log D/ChatActivity: Received: user2: hello from android常见错误表Logcat错误根本原因解决方案android.os.NetworkOnMainThreadException在主线程执行Socket连接将new Socket(host, port)移至AsyncTask或Thread中java.net.SocketTimeoutException: failed to connect服务端IP/端口错误或网络不通用ping 192.168.1.100和telnet 192.168.1.100 8080验证连通性java.io.IOException: Broken pipe服务端已关闭连接客户端仍尝试写入在PrintWriter.println()前增加if (out.checkError())判断5. 进阶技巧用Telnet模拟客户端快速验证服务端逻辑不必每次启动Android App才能测试服务端telnet是最轻量的Socket客户端验证工具。在Ubuntu或macOS终端执行telnet 127.0.0.1 8080 # 或连接局域网服务端 telnet 192.168.1.100 8080成功连接后按协议格式输入注意每行结尾需按Enteruser1 hello world服务端控制台将输出Client user1 connected Received from user1: hello world此时再开第二个telnet窗口输入user2 are you there?第一个窗口将收到广播user2: are you there?提示若telnet命令不存在Ubuntu需安装sudo apt install telnetmacOS Catalina后需启用/System/Applications/Utilities/Terminal.app中telnet或用nc -v 127.0.0.1 8080替代。5.1 用Python脚本批量模拟压力测试当需验证服务端并发能力时编写简易压测脚本# stress_test.py import socket import threading import time def client_task(client_id): try: s socket.socket(socket.AF_INET, socket.SOCK_STREAM) s.connect((127.0.0.1, 8080)) s.sendall(fuser{client_id}\n.encode()) time.sleep(0.1) s.sendall(fHello from client {client_id}\n.encode()) s.close() print(fClient {client_id} done) except Exception as e: print(fClient {client_id} error: {e}) # 启动10个并发客户端 threads [] for i in range(10): t threading.Thread(targetclient_task, args(i,)) threads.append(t) t.start() for t in threads: t.join()运行后观察服务端控制台是否打印10条Client userX connected及对应消息。若出现Connection refused说明服务端ServerSocket连接队列满默认50需在构造时指定更大backlogServerSocket serverSocket new ServerSocket(PORT, 100); // 第二个参数为backlog此脚本直接暴露了BIO模型的并发瓶颈——当并发连接数超过线程数本项目为CPU核心数×2新连接将排队等待。这正是驱动你学习NIO/Netty的最真实动因。本文还有配套的精品资源点击获取 Android原生Socket即时通讯实战：TCP长连接与消息协议设计
简介本资源是一套基于Socket通信实现的Android端仿微信即时通讯软件完整源码面向Android开发初学者与中级工程师适用于网络编程、客户端-服务器架构设计及IM应用开发学习场景。压缩包共797个文件包含76个Java核心逻辑代码、78个XML布局与配置文件、368张UI资源PNG图、133个编译后Class字节码以及服务端相关SQL脚本、技术文档、消息类型定义、组件缩写说明等配套材料整体体积10.64MB结构清晰便于分层理解客户端通信机制与服务端协同逻辑。已有288人下载学习读者可直接运行调试Client.apk与服务端程序掌握长连接管理、消息收发流程、UI交互设计及常见Bug修复记录同时获取命名规范、生命周期控制、消息类型建模等工程实践参考。1. 这不是又一个“仿微信”Demo而是一套可调试、可扩展的Android端到端Socket通信最小可行系统很多开发者下载“仿微信源码”后发现UI能跑消息发不出去服务端启动了客户端连不上Logcat里满屏IOException: socket failed: ECONNREFUSED却不知从哪改起。这套Android仿微信聊天软件Socket实现源码包含服务端.zip真正价值在于——它剥离了IM SDK黑盒封装用原生Java Socket非WebSocket、非Netty封装层直连TCP长连接完整呈现了客户端心跳保活、服务端多线程连接管理、消息协议编码/解码、离线消息暂存逻辑四个硬核模块。适合Android中级开发者2~5年经验用于理解即时通讯底层链路也适合作为毕业设计或企业内部轻量级协作工具的技术基座。它不追求UI还原度但每个.java文件都标注了关键通信状态流转节点服务端用纯JavaServerSocket实现无需额外部署Tomcat或Spring Boot容器javac java两步即可验证通路。2. 为什么选原生Socket而非OkHttp/WebSocket从协议分层看通信可靠性设计2.1 即时通讯场景下TCP长连接的核心诉求与Socket的不可替代性在移动端IM开发中高频小包、低延迟、强连接状态感知是刚需。HTTP短连接每次交互需三次握手TLS协商微信类应用每秒可能产生数十次状态同步输入状态、已读回执、Typing提示若走HTTP轮询或长轮询网络开销和服务器负载呈指数级增长。而原生Socket直接工作在传输层客户端与服务端建立一次TCP连接后可复用该连接发送任意次数消息且通过setSoTimeout()、isClosed()、isConnected()等API实时感知链路健康度。本项目服务端ChatServer.java中while (true)循环内serverSocket.accept()阻塞等待新连接正是对OSI模型第四层传输层能力的直接调用——这比任何上层封装如OkHttp的WebSocket更贴近网络本质也更利于排查EADDRINUSE、ECONNRESET等底层错误。提示项目未使用Netty或Mina等NIO框架是因为其目标是教学可读性。对于生产环境高并发场景应升级为基于Selector的NIO实现但本源码的Thread per Connection模型恰好暴露了传统BIO的瓶颈点为后续优化提供明确靶点。2.2 消息协议设计用固定头变长体解决粘包与拆包问题Socket传输的是字节流而非消息边界清晰的数据包。若客户端连续发送hello和world服务端InputStream.read(buffer)可能一次性读到helloworld粘包也可能分两次读到hel和loworld拆包。本项目采用经典TLVType-Length-Value结构// ClientMessage.java 中定义协议头 public class ClientMessage { public static final int MSG_TYPE_TEXT 1; public static final int MSG_TYPE_HEARTBEAT 2; private int type; // 4字节消息类型 private int length; // 4字节后续内容长度不含头 private String content; // 变长UTF-8字符串 // 序列化为byte[][type:int][length:int][content:bytes] public byte[] toBytes() { byte[] contentBytes content.getBytes(StandardCharsets.UTF_8); ByteBuffer buffer ByteBuffer.allocate(8 contentBytes.length); buffer.putInt(type); buffer.putInt(contentBytes.length); buffer.put(contentBytes); return buffer.array(); } }服务端ChatHandler.java中解析逻辑严格按此结构读取// 读取固定8字节头部 byte[] header new byte[8]; int read inputStream.read(header); if (read ! 8) throw new IOException(Header incomplete); ByteBuffer headerBuffer ByteBuffer.wrap(header); int type headerBuffer.getInt(); int length headerBuffer.getInt(); // 再读取length字节内容 byte[] contentBytes new byte[length]; read inputStream.read(contentBytes); if (read ! length) throw new IOException(Content incomplete);2.2.1 关键参数说明与调试技巧参数位置作用调试建议type协议头前4字节区分文本消息、心跳、登录请求等语义在Wireshark中过滤tcp.port 8080 tcp.len 8右键Follow → TCP Stream查看原始字节验证前4字节是否为00 00 00 01MSG_TYPE_TEXTlength协议头后4字节告知接收方后续内容字节数避免无限读取若服务端卡死在inputStream.read(contentBytes)检查客户端是否正确写入了content.length而非content.length()1content头部后变长部分UTF-8编码的消息体支持中文Android端发送含中文消息时确保content.getBytes(StandardCharsets.UTF_8)与服务端new String(bytes, StandardCharsets.UTF_8)编码一致否则出现乱码2.3 客户端连接管理从Activity生命周期到Socket状态机的映射Android Activity可能因屏幕旋转、内存回收被销毁重建但Socket连接必须保持存活。本项目在ChatActivity.java中将Socket声明为static并配合Application级别生命周期管理public class ChatApplication extends Application { private static Socket clientSocket; private static PrintWriter out; private static BufferedReader in; public static void connect(String host, int port) throws IOException { if (clientSocket null || !clientSocket.isConnected() || clientSocket.isClosed()) { clientSocket new Socket(host, port); out new PrintWriter(clientSocket.getOutputStream(), true); in new BufferedReader(new InputStreamReader(clientSocket.getInputStream())); } } // 提供静态方法供Activity调用 public static void sendMessage(String msg) { if (out ! null) out.println(msg); // 注意此处简化实际应走ClientMessage.toBytes() } }注意static Socket在进程被杀后会失效此设计仅适用于前台活跃场景。生产环境需改用ServiceForeground Service保活并监听ConnectivityManager.CONNECTIVITY_ACTION广播处理网络切换。3. 服务端核心实现多线程连接池与内存级消息路由3.1 ServerSocket基础架构与连接拒绝策略服务端入口ChatServer.java启动流程极简public class ChatServer { private static final int PORT 8080; private static final ListChatHandler clients Collections.synchronizedList(new ArrayList()); public static void main(String[] args) throws IOException { ServerSocket serverSocket new ServerSocket(PORT); System.out.println(Chat server started on port PORT); while (true) { Socket clientSocket serverSocket.accept(); // 阻塞等待连接 ChatHandler handler new ChatHandler(clientSocket); Thread thread new Thread(handler); thread.start(); clients.add(handler); } } }此处ServerSocket(PORT)隐含关键配置若端口被占用抛出java.net.BindException: Address already in use。常见原因包括其他Java进程占用了8080端口lsof -i :8080或netstat -ano | findstr :8080上次服务异常退出Socket处于TIME_WAIT状态Linux默认60秒需等待或改用SO_REUSEADDRWindows防火墙拦截入站连接需在防火墙设置中允许Java SE Binary3.2 ChatHandler线程封装单连接全生命周期每个ChatHandler实例对应一个客户端连接其run()方法实现完整状态机public class ChatHandler implements Runnable { private Socket socket; private BufferedReader in; private PrintWriter out; private String clientId; Override public void run() { try { in new BufferedReader(new InputStreamReader(socket.getInputStream())); out new PrintWriter(socket.getOutputStream(), true); // 1. 登录握手读取首行作为clientId clientId in.readLine(); if (clientId null) return; System.out.println(Client clientId connected); // 2. 主循环持续读取消息并广播 String inputLine; while ((inputLine in.readLine()) ! null) { System.out.println(Received from clientId : inputLine); broadcast(clientId, inputLine); // 广播给其他所有客户端 } } catch (IOException e) { System.err.println(Client clientId disconnected: e.getMessage()); } finally { cleanup(); } } private void broadcast(String sender, String message) { synchronized (clients) { for (ChatHandler client : clients) { if (!client.clientId.equals(sender) client.out ! null) { client.out.println(sender : message); } } } } private void cleanup() { clients.remove(this); try { if (socket ! null) socket.close(); } catch (IOException e) { e.printStackTrace(); } } }3.2.1 线程安全关键点分析场景风险本项目解决方案生产环境升级建议多线程并发修改clients列表ConcurrentModificationException使用Collections.synchronizedList()包装改用CopyOnWriteArrayList避免迭代时加锁广播时某客户端Socket已断开NullPointerExceptiononclient.outif (client.out ! null)空值检查增加client.socket.isClosed()双重校验客户端发送超长消息导致readLine()阻塞OOM或线程饥饿无显式限制依赖TCP缓冲区在BufferedReader构造时指定new InputStreamReader(socket.getInputStream(), StandardCharsets.UTF_8, 8192)3.3 消息广播机制的局限性与离线消息改造路径当前广播逻辑broadcast()仅向在线客户端推送若用户A发送消息时用户B离线则B永远收不到。要支持离线消息需引入内存级队列// 新增离线消息存储生产环境应替换为Redis或数据库 private static final MapString, QueueString offlineMessages new ConcurrentHashMap(); // 在broadcast中若目标client不在线则存入队列 if (!client.clientId.equals(sender) client.out ! null) { client.out.println(sender : message); } else { offlineMessages.computeIfAbsent(client.clientId, k - new ConcurrentLinkedQueue()) .add(sender : message); } // 客户端重连时在ChatHandler.run()登录后立即推送 ListString pending offlineMessages.remove(clientId); if (pending ! null) { for (String msg : pending) { out.println([OFFLINE] msg); } }4. Android客户端实战从Android Studio编译到真机调试的完整链路4.1 环境准备与APK构建项目提供Client.apk但为深入理解需自行编译。使用Android Studio打开app/目录需确认build.gradle中compileSdkVersion与本地SDK匹配android { compileSdkVersion 33 // 根据你安装的SDK版本调整 defaultConfig { applicationId com.example.chatclient minSdkVersion 21 // Socket通信最低要求Android 5.0 targetSdkVersion 33 } }关键依赖仅需androidx.appcompat:appcompat无第三方网络库dependencies { implementation androidx.appcompat:appcompat:1.6.1 implementation com.google.android.material:material:1.9.0 }编译命令终端进入项目根目录# 生成debug APK ./gradlew assembleDebug # APK路径app/build/outputs/apk/debug/app-debug.apk提示若遇到Failed to install app-debug.apk: Failure [INSTALL_FAILED_USER_RESTRICTED]需在手机开发者选项中关闭“USB调试安全设置”。4.2 权限配置与网络访问白名单Android 9API 28以上默认禁止HTTP明文流量。服务端使用http://地址如192.168.1.100:8080需在AndroidManifest.xml中添加application android:usesCleartextTraffictrue ... uses-permission android:nameandroid.permission.INTERNET / uses-permission android:nameandroid.permission.ACCESS_NETWORK_STATE / /application对于Android 10还需在res/xml/network_security_config.xml中显式允许?xml version1.0 encodingutf-8? network-security-config domain-config domain includeSubdomainstrue192.168.1.100/domain cleartextTrafficPermittedtrue / /domain-config /network-security-config并在AndroidManifest.xml中引用application android:networkSecurityConfigxml/network_security_config ... 4.3 真机调试关键步骤与典型错误定位步骤1确认服务端IP可达在Android设备浏览器中访问http://192.168.1.100:8080服务端所在电脑局域网IP若返回Connection refused说明服务端未运行或防火墙拦截若超时检查手机与电脑是否在同一WiFi子网。步骤2抓包验证Socket连接使用Packet CapturePlay Store应用或Wireshark电脑端捕获设备流量过滤条件tcp.port 8080正常流程SYN → SYN-ACK → ACK → [PSH, ACK]发送clientId→[PSH, ACK]发送消息异常信号仅出现SYN无响应 → 服务端未监听出现RST→ 服务端主动拒绝步骤3Logcat关键日志解读// 成功连接 D/ChatActivity: Connected to 192.168.1.100:8080 // 发送失败服务端宕机 W/System.err: java.net.ConnectException: Connection refused // 接收消息需在ChatActivity中添加log D/ChatActivity: Received: user2: hello from android常见错误表Logcat错误根本原因解决方案android.os.NetworkOnMainThreadException在主线程执行Socket连接将new Socket(host, port)移至AsyncTask或Thread中java.net.SocketTimeoutException: failed to connect服务端IP/端口错误或网络不通用ping 192.168.1.100和telnet 192.168.1.100 8080验证连通性java.io.IOException: Broken pipe服务端已关闭连接客户端仍尝试写入在PrintWriter.println()前增加if (out.checkError())判断5. 进阶技巧用Telnet模拟客户端快速验证服务端逻辑不必每次启动Android App才能测试服务端telnet是最轻量的Socket客户端验证工具。在Ubuntu或macOS终端执行telnet 127.0.0.1 8080 # 或连接局域网服务端 telnet 192.168.1.100 8080成功连接后按协议格式输入注意每行结尾需按Enteruser1 hello world服务端控制台将输出Client user1 connected Received from user1: hello world此时再开第二个telnet窗口输入user2 are you there?第一个窗口将收到广播user2: are you there?提示若telnet命令不存在Ubuntu需安装sudo apt install telnetmacOS Catalina后需启用/System/Applications/Utilities/Terminal.app中telnet或用nc -v 127.0.0.1 8080替代。5.1 用Python脚本批量模拟压力测试当需验证服务端并发能力时编写简易压测脚本# stress_test.py import socket import threading import time def client_task(client_id): try: s socket.socket(socket.AF_INET, socket.SOCK_STREAM) s.connect((127.0.0.1, 8080)) s.sendall(fuser{client_id}\n.encode()) time.sleep(0.1) s.sendall(fHello from client {client_id}\n.encode()) s.close() print(fClient {client_id} done) except Exception as e: print(fClient {client_id} error: {e}) # 启动10个并发客户端 threads [] for i in range(10): t threading.Thread(targetclient_task, args(i,)) threads.append(t) t.start() for t in threads: t.join()运行后观察服务端控制台是否打印10条Client userX connected及对应消息。若出现Connection refused说明服务端ServerSocket连接队列满默认50需在构造时指定更大backlogServerSocket serverSocket new ServerSocket(PORT, 100); // 第二个参数为backlog此脚本直接暴露了BIO模型的并发瓶颈——当并发连接数超过线程数本项目为CPU核心数×2新连接将排队等待。这正是驱动你学习NIO/Netty的最真实动因。本文还有配套的精品资源点击获取