Socket通信在移动应用中的实现

发布时间:2024-09-03 15:16:24

阅读量:132

Socket 通信是一种在移动应用中实现实时数据传输的技术

创建 Socket 对象：首先，你需要创建一个 Socket 对象，该对象将负责与服务器进行通信。在 Android 中，你可以使用 java.net.Socket 类来创建 Socket 对象。

import java.io.IOException;
import java.net.Socket;

public class MainActivity extends AppCompatActivity {
    private Socket socket;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    socket = new Socket("your_server_ip", your_server_port);
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }).start();
    }
}

输入/输出流：为了在 Socket 上发送和接收数据，你需要创建输入/输出流。在 Android 中，你可以使用 java.io.InputStream 和 java.io.OutputStream 类来实现这一点。

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;

public class MainActivity extends AppCompatActivity {
    private Socket socket;
    private InputStream inputStream;
    private OutputStream outputStream;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    socket = new Socket("your_server_ip", your_server_port);
                    inputStream = socket.getInputStream();
                    outputStream = socket.getOutputStream();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }).start();
    }
}

发送数据：通过输出流将数据发送到服务器。在 Android 中，你可以使用 write() 方法将字节数组写入输出流。

public void sendData(String data) {
    if (outputStream != null) {
        try {
            outputStream.write(data.getBytes());
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

接收数据：从输入流中读取服务器发送的数据。在 Android 中，你可以使用 read() 方法从输入流中读取字节数组。

public String receiveData() {
    if (inputStream != null) {
        try {
            byte[] buffer = new byte[1024];
            int bytesRead = inputStream.read(buffer);
            return new String(buffer, 0, bytesRead);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    return null;
}

关闭连接：在不再需要 Socket 连接时，确保关闭输入/输出流和 Socket 对象以释放资源。

public void closeConnection() {
    if (inputStream != null) {
        try {
            inputStream.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    if (outputStream != null) {
        try {
            outputStream.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    if (socket != null) {
        try {
            socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}