tcp和udp的区别,测试实例.doc

package com.server;import java.io.OutputStreamWriter;import .Socket;public class TCPClient /* * param args * author zzy */public static void main(String args) throws Exception Socket s = new Socket(, 8083);OutputStreamWriter w = new OutputStreamWriter(s.getOutputStream();w.write(这里是客户端，Hello服务器,准备发到服务器端);w.flush();w.close();s.close();package com.server;import java.io.InputStreamReader;import .ServerSocket;import .Socket;public class TCPServer /* * param args * author zzy */public static void main(String args) throws Exception ServerSocket ss = new ServerSocket(8083);while (true) Socket s = ss.accept();System.err.println(A client has heen connected.);System.err.println(这里是服务器端+TCPServer.class);InputStreamReader r = new InputStreamReader(s.getInputStream();int c = 0;while (c = r.read() -1) System.err.print(char) c);r.close();s.close();package com.server;import java.io.IOException;import .DatagramPacket;import .DatagramSocket;import .InetAddress;public class UDPClient private bytebuffer= new byte1024;private DatagramSocketds= null;/* * 构造函数，创建UDP客户端 * * throws Exception * author zzy */public UDPClient() throws Exception ds = new DatagramSocket();/* * 设置超时时间，该方法必须在bind方法之后使用. * * param timeout * 超时时间 * throws Exception * author zzy */public final void setSoTimeout(final int timeout) throws Exception ds.setSoTimeout(timeout);/* * 获得超时时间. * * return 返回超时时间 * throws Exception * author zzy */public final int getSoTimeout() throws Exception return ds.getSoTimeout();public final DatagramSocket getSocket() return ds;/* * 向指定的服务端发送数据信息. * * param host * 服务器主机地址 * param port * 服务端端口 * param bytes * 发送的数据信息 * return 返回构造后俄数据报 * throws IOException * author zzy */public final DatagramPacket send(final String host, final int port,final byte bytes) throws IOException DatagramPacket dp = new DatagramPacket(bytes, bytes.length, InetAddress.getByName(host), port);ds.send(dp);return dp;/* * 接收从指定的服务端发回的数据. * * param lhost * 服务端主机 * param lport * 服务端端口 * return 返回从指定的服务端发回的数据. * throws Exception * author zzy */public final String receive(final String lhost, final int lport)throws Exception DatagramPacket dp = new DatagramPacket(buffer, buffer.length);ds.receive(dp);String info = new String(dp.getData(), 0, dp.getLength();return info;/* * 关闭udp连接. * */public final void close() try ds.close(); catch (Exception ex) ex.printStackTrace();/* * 测试客户端发包和接收回应信息的方法. * * param args * throws Exception * author zzy */public static void main(String args) throws Exception UDPClient client = new UDPClient();String serverHost = ;int serverPort = 3366;client.send(serverHost, serverPort, (你好!).getBytes();String info = client.receive(serverHost, serverPort);System.out.println(服务端回应数据： + info);package com.server;import java.io.IOException;import .DatagramPacket;import .DatagramSocket;import .InetAddress;import .InetSocketAddress;import .SocketException;/* * author zzy * */public class UDPServer private bytebuffer= new byte1024;private DatagramSocketds= null;private DatagramPacketpacket= null;private InetSocketAddresssocketAddress= null;private StringorgIp;/* * 构造函数，绑定主机和端口. * * param host * 主机 * param port * 端口 * throws Exception */public UDPServer(String host, int port) throws Exception socketAddress = new InetSocketAddress(host, port);ds = new DatagramSocket(socketAddress);System.out.println(服务端启动!);public final String getOrgIp() return orgIp;/* * 设置超时时间，该方法必须在bind方法之后使用. * * param timeout * 超时时间 * throws Exception */public final void setSoTimeout(int timeout) throws Exception ds.setSoTimeout(timeout);/* * 获得超时时间. * * return 返回超时时间. * throws Exception */public final int getSoTimeout() throws Exception return ds.getSoTimeout();/* * 绑定监听地址和端口. * * param host * 主机IP * param port * 端口 * throws SocketException */public final void bind(String host, int port) throws SocketException socketAddress = new InetSocketAddress(host, port);ds = new DatagramSocket(socketAddress);/* * 接收数据包，该方法会造成线程阻塞. * * return 返回接收的数据串信息 * throws IOException */public final String receive() throws IOException packet = new DatagramPacket(buffer, buffer.length);ds.receive(packet);orgIp = packet.getAddress().getHostAddress();String info = new String(packet.getData(), 0, packet.getLength();System.out.println(接收信息： + info);return info;/* * 将响应包发送给请求端. * * param bytes * 回应报文 * throws IOException */public final void response(String info) throws IOException System.out.println(客户端地址 : + packet.getAddress().getHostAddress()+ ,端口： + packet.getPort();DatagramPacket dp = new DatagramPacket(buffer, buffer.length, packet.getAddress(), packet.getPort();dp.setData(info.getBytes();ds.send(dp);/* * 设置报文的缓冲长度. * * param bufsize * 缓冲长度 */public final void setLength(int bufsize) packet.setLength(bufsize);/* * 获得发送回应的IP地址. * * return 返回回应的IP地址 */public final InetAddress getResponseAddress() return packet.getAddress();/* * 获得回应的主机的端口. * * return 返回回应的主机的端口. */public final int getResponsePort() return packet.getPort();/* * 关闭udp监听口. * */public final void close() try ds.close(); catch (Exception ex) ex.printStackTrace();/* * 测试方法. * * param ar