当前位置：首页 > 行业动态 > 正文

安卓实现与服务器tcp通信

admin
行业动态
2025-04-21
2

权限配置

在AndroidManifest.xml中添加网络权限：

<uses-permission android:name="android.permission.INTERNET" />

若需访问局域网,还需添加：

<uses-permission android:name="android.permission.ACCESS_WIFI_STATE" />
<uses-permission android:name="android.permission.CHANGE_WIFI_STATE" />

网络操作线程处理

Socket通信核心代码

// 1. 创建Socket连接
Socket socket = new Socket();
SocketAddress serverAddress = new InetSocketAddress("192.168.1.100", 8888); // 替换为服务器IP和端口
socket.connect(serverAddress, 5000); // 设置5秒超时时间
// 2. 获取输入输出流
OutputStream outputStream = socket.getOutputStream();
InputStream inputStream = socket.getInputStream();
// 3. 发送数据
String message = "Hello Server";
outputStream.write(message.getBytes());
outputStream.flush();
// 4. 接收数据
byte[] buffer = new byte[1024];
int len = inputStream.read(buffer);
String response = new String(buffer, 0, len);
// 5. 关闭资源
outputStream.close();
inputStream.close();
socket.close();

完整示例（带异常处理）

public class TcpClient {
    private static final String SERVER_IP = "192.168.1.100"; // 服务器IP
    private static final int SERVER_PORT = 8888;            // 服务器端口
    private static final int TIMEOUT = 5000;               // 超时时间(ms)
    public static void startConnection() {
        new Thread(() -> {
            try {
                // 创建Socket并连接
                Socket socket = new Socket();
                socket.connect(new InetSocketAddress(SERVER_IP, SERVER_PORT), TIMEOUT);
                // 获取流对象
                OutputStream os = socket.getOutputStream();
                InputStream is = socket.getInputStream();
                // 发送数据
                String sendData = "Request Data";
                os.write(sendData.getBytes());
                os.flush();
                // 接收数据
                byte[] buffer = new byte[1024];
                int readLen = is.read(buffer);
                String receiveData = new String(buffer, 0, readLen);
                // 打印结果（实际应通过Handler更新UI）
                Log.d("TCP_CLIENT", "Received: " + receiveData);
                // 关闭资源
                is.close();
                os.close();
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }).start();
    }
}

本地测试服务器搭建

Python简易服务器（适合测试）

# 在PC端运行（需安装Python）
python -m http.server 8888 # HTTP服务器（非TCP）

Python TCP服务器示例

# tcp_server.py
import socket
HOST = '0.0.0.0'  # 监听所有接口
PORT = 8888      # 端口号
with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
    s.bind((HOST, PORT))
    s.listen()
    print(f"Server listening on {PORT}...")
    conn, addr = s.accept()
    with conn:
        print(f"Connected by {addr}")
        while True:
            data = conn.recv(1024)
            if not data:
                break
            print(f"Received: {data.decode()}")
            conn.sendall(b"Echo: " + data)  # 回显数据

使用Netcat工具（Linux/Mac）

# 在终端运行（模拟TCP服务器）
nc -l -p 8888   # 监听8888端口

常见问题及解决方案

问题现象	原因分析	解决方案
`NetworkOnMainThreadException`	主线程执行网络操作	移至子线程或使用异步框架
`ECONNREFUSED`	服务器未启动/IP/端口错误	检查服务器状态及配置信息
`Permission denied`	未声明INTERNET权限	添加`<uses-permission>`
数据接收不完整	未正确处理流结束或缓冲区大小不当	循环读取直到流结束
SSL握手失败	使用HTTPS但未配置证书	启用SSLSocket并加载证书