socket编程 UDP和TCP 通信示例.docx

android开发之socket编程UDP和TCP通信实现原理图应用程序通过套接字通信，其协议如下：UDP ： 把数据打包后直接发送给相应的IP ，数据大小有限制，连接不可靠。TCP ：服务器与客户端协议必须匹配，即都是用 TCP 协议，先建立连接，再发送数据，其连接可靠。通信方式如下图所示：代码示例UDP 通信：UDP 使用 DatagramSocket 对象实现数据交互。客户端客户端示例代码如下：import .DatagramPacket;import .DatagramSocket;import .InetAddress;public class Client public static void main(String args) try / 创建一个 DatagramSocket 对象，不要有端口号，否则设置的端口被本类独占。 DatagramSocket socket = new DatagramSocket(); / 创建一个 InetAddress InetAddress serverAddress = InetAddress.getByName(); / 创建传输字符串 String str = hello; / 转换成字节数组 byte data = str.getBytes(); / 创建以供 DatagramPacket 对象， 指定其发送地址和端口号 DatagramPacket packet = new DatagramPacket(data, data.length, serverAddress, 4567); / 调用 socket 对象的 send()方法发送数据 socket.send(packet); catch (Exception e) e.printStackTrace(); 服务器端服务器示例代码如下：import java.io.IOException;import .DatagramPacket;import .DatagramSocket;import .SocketException;public class Server public static void main(String args) / 创建一个 DatagramSocket 对象，指定端口为4567 try DatagramSocket socket = new DatagramSocket(4567); byte data = new byte1024; / 创建一个空 DatagramPacket 对象 DatagramPacket packet = new DatagramPacket(data, data.length); / 使用 receiver 方法接手客户端所发送到数据， 如果客户端没有发送数据， 进程阻塞 socket.receive(packet); String result = new String(packet.getData(), packet.getOffset(), packet.getLength(); System.out.println(result - + result); catch (SocketException e) e.printStackTrace(); catch (IOException e) e.printStackTrace(); 运行结果：PS：Windows下查看端口：netstat -n -a | find 4567TCP 通信：TCP 通信需先建立连接，然后进行数据通信。客户端import java.io.FileInputStream;import java.io.IOException;import java.io.InputStream;import java.io.OutputStream;import .Socket;import .UnknownHostException;public class Client public static void main(String args) try / 创建一个 Socket 对象， 指定服务器端的 IP 地址和端口号 Socket socket = new Socket(, 4567); / 使用 InputStream 读取硬盘上的文件 InputStream inputStream = new FileInputStream(D:aa.txt); / 从 Socket 当中得到 OutputStream OutputStream outputStream = socket.getOutputStream(); byte buffer = new byte4 * 1024; int temp = 0; / 将 InputStream 当中的数据取出， 并写入到 OutputStream 当中 while (temp = inputStream.read(buffer) != -1) outputStream.write(buffer, 0, temp); outputStream.flush(); / 必须关闭，否则有 reset 异常 outputStream.close(); socket.close(); catch (UnknownHostException e) e.printStackTrace(); catch (IOException e) e.printStackTrace(); 服务器端import java.io.IOException;import java.io.InputStream;import .ServerSocket;import .Socket;public class Server public static void main(String args) / 声明一个 ServerSocket 对象 ServerSocket serverSocket = null; try / 创建一个 ServerSocket 对象， 并让这个Socket 在4567 端口监听 serverSocket = new ServerSocket(4567); / 调用 ServerSocket 的accept() 方法， 接受客户端所发送到请求，如果客户端没有发送数据，那么该线程就停滞不继续 Socket socket = serverSocket.accept(); / 从 Socket 当中得到 InputStream 对象 InputStream inputStream = socket.getInputStream(); byte buffer = new byte1024 * 4; int temp = 0; / 从 InputStream 中读取客户端数据 while (temp = inputStream.read(buffer) != -1) System