java Udp 收发结构体实例 Socket编程

/* * To change this template, choose Tools | Templates * and open the template in the editor. */ /** * * @author WLL * @ E-mail [email protected] */ import java.io.ByteArrayInputStream; import java.io.IOException; import java.io.ObjectInputStream; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; import java.net.InetSocketAddress; import java.net.SocketException; import java.util.logging.Level; import java.util.logging.Logger; /** * Copyright 2007 GuangZhou Cotel Co. Ltd. * All right reserved. * UTP服务类. * @author <a href="mailto:[email protected]">AmigoXie</a> * @version 1.0 * Creation date: 2007-8-16 - 下午10:32:31 */ public class UdpServerSocket { private byte[] buffer = new byte[1024]; private DatagramSocket ds = null; private DatagramPacket packet = null; private InetSocketAddress socketAddress = null; private String orgIp; /** * 构造函数，绑定主机和端口. * @param host 主机 * @param port 端口 * @throws Exception */ public UdpServerSocket(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 * @author <a href="mailto:[email protected]">AmigoXie</a> * Creation date: 2007-8-16 - 下午10:34:36 */ public final int getSoTimeout() throws Exception { return ds.getSoTimeout(); } /** * 绑定监听地址和端口. * @param host 主机IP * @param port 端口 * @throws SocketException * @author <a href="mailto:[email protected]">AmigoXie</a> * Creation date: 2007-8-16 - 下午10:36:17 */ public final void bind(String host, int port) throws SocketException { socketAddress = new InetSocketAddress(host, port); ds = new DatagramSocket(socketAddress); } /** * 接收数据包，该方法会造成线程阻塞. * @return 返回接收的数据串信息 * @throws IOException * @author <a href="mailto:[email protected]">AmigoXie</a> * Creation date: 2007-8-16 - 下午10:38:24 */ 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 * @author <a href="mailto:[email protected]">AmigoXie</a> * Creation date: 2007-8-16 - 下午11:05:31 */ 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 缓冲长度 * @author <a href="mailto:[email protected]">AmigoXie</a> * Creation date: 2007-8-16 - 下午10:47:49 */ public final void setLength(int bufsize) { packet.setLength(bufsize); } /** * 获得发送回应的IP地址. * @return 返回回应的IP地址 * @author <a href="mailto:[email protected]">AmigoXie</a> * Creation date: 2007-8-16 - 下午10:48:27 */ public final InetAddress getResponseAddress() { return packet.getAddress(); } /** * 获得回应的主机的端口. * @return 返回回应的主机的端口. * @author <a href="mailto:[email protected]">AmigoXie</a> * Creation date: 2007-8-16 - 下午10:48:56 */ public final int getResponsePort() { return packet.getPort(); } /** * 关闭udp监听口. * @author <a href="mailto:[email protected]">AmigoXie</a> * Creation date: 2007-8-16 - 下午10:49:23 */ public final void close() { try { ds.close(); } catch (Exception ex) { ex.printStackTrace(); } } /** * 测试方法. * @param args * @throws Exception * @author <a href="mailto:[email protected]">AmigoXie</a> * Creation date: 2007-8-16 - 下午10:49:50 */ public static void main(String[] args) throws Exception { // String serverHost = "127.0.0.1"; // int serverPort = 3344; // UdpServerSocket udpServerSocket = new UdpServerSocket(serverHost, serverPort); // while (true) { // udpServerSocket.receive(); // udpServerSocket.response("你好,sterning!"); // // } UdpReceiveData("127.0.0.1", 10000); } public static UrlBean UdpReceiveData(String IP, int port) throws IOException, ClassNotFoundException { byte[] buffer = new byte[1024]; DatagramSocket ds = null; DatagramPacket packet = null; InetSocketAddress socketAddress = null; String orgIp; UrlBean obj = null; socketAddress = new InetSocketAddress(IP, port); ds = new DatagramSocket(socketAddress); System.out.println("服务端启动!"); while (true) { packet = new DatagramPacket(buffer, buffer.length); ds.receive(packet); orgIp = packet.getAddress().getHostAddress(); String info = new String(packet.getData(), 0, packet.getLength());//String 型不需要特殊处理 System.out.println("接收信息：" + info); obj = getByteArraytoObj(packet.getData()); System.out.println("接收Url：" + obj.getUrl()+","+"接收的Webname："+obj.getWebName()); 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); if (obj != null) { break; } } return obj; } //接收流信息转为obj public static UrlBean getByteArraytoObj(byte[] buffer) { UrlBean obj = null; try { ByteArrayInputStream buffers = new ByteArrayInputStream(buffer); ObjectInputStream in = new ObjectInputStream(buffers); obj = (UrlBean) in.readObject(); in.close(); } catch (Exception e) { System.out.println("error"); } return obj; } }