UDP服务端向客户端传输list对象

2023-12-11 16:57:16

https://www.oschina.net/question/1449495_149180

java序列化：

Java 提供了一种对象序列化的机制，该机制中，一个对象可以被表示为一个字节序列，该字节序列包括该对象的数据、有关对象的类型的信息和存储在对象中数据的类型。
将序列化对象写入文件之后，可以从文件中读取出来，并且对它进行反序列化，也就是说，对象的类型信息、对象的数据，还有对象中的数据类型可以用来在内存中新建对象。
整个过程都是 Java 虚拟机（JVM）独立的，也就是说，在一个平台上序列化的对象可以在另一个完全不同的平台上反序列化该对象。
类 ObjectInputStream 和 ObjectOutputStream 是高层次的数据流，它们包含反序列化和序列化对象的方法。

序列化：

public final void writeObject(Object x) throws IOException
上面的方法序列化一个对象，并将它发送到输出流。

反序列化：

public final Object readObject() throws IOException, ClassNotFoundException
该方法从流中取出下一个对象，并将对象反序列化。它的返回值为Object，因此，你需要将它转换成合适的数据类型。

如何序列化一个类

请注意，一个类的对象要想序列化成功，必须满足两个条件：

该类必须实现 java.io.Serializable 接口。

public class Employee implements java.io.Serializable
{
   public String name;
   public String address;
   public transient int SSN;
   public int number;
   public void mailCheck()
   {
      System.out.println("Mailing a check to " + name
                           + " " + address);
   }
}

ByteArrayOutputStream类：

字节数组输出流在内存中创建一个字节数组缓冲区，所有发送到输出流的数据保存在该字节数组缓冲区中。创建字节数组输出流对象有以下几种方式。

方法：
public byte[] toByteArray()
创建一个新分配的字节数组。数组的大小和当前输出流的大小，内容是当前输出流的拷贝。

public String toString()
将缓冲区的内容转换为字符串，根据平台的默认字符编码将字节转换成字符。

udp传输list对象：

server类

public class UDPServer {
	@SuppressWarnings("unchecked")
	public static void main(String[] args) {
		
		DatagramSocket server = null;
		ObjectInputStream ois = null;
		try {
			byte[] buffer = new byte[1024];
			int port = 8888;
			boolean listening = true;
			server = new DatagramSocket(port);
			DatagramPacket packet = new DatagramPacket(buffer, buffer.length);
			
			System.out.println("waiting to receive data...");
			while (listening){
				server.receive(packet); //receive a datagrampacket blockly
				System.out.println("receive from " + packet.getAddress() + ":" + packet.getPort());
				// read
				try {
					ois = new ObjectInputStream(new ByteArrayInputStream(packet.getData()));
					List<Person> ps = (List<Person>)ois.readObject();
					for (Person p : ps){
						System.out.println(p);
					}
				} catch (ClassNotFoundException e) {
					e.printStackTrace();
				} finally{
					if (ois != null) ois.close();
				}
				//for next packet
				packet.setLength(buffer.length);
			}
		} catch (IOException e) {
			e.printStackTrace();
		} finally{
			if (server != null){
				server.close();
			}
		}
	}
}

client类

public class UDPClient {
	public static void main(String[] args) throws UnsupportedEncodingException {
		int bufferSize = 1024;
		
		ObjectOutputStream oos = null;
		DatagramSocket client = null;
		try {
			ByteArrayOutputStream baos = new ByteArrayOutputStream(bufferSize);
			oos = new ObjectOutputStream(baos);

			List<Person> ps = new ArrayList<>();
			for (int i=0; i<5; i++){
				ps.add(new Person("person1", i+20));
			}
			System.out.println("write data");
			oos.writeObject(ps); //write object to byte output stream
			byte[] data = baos.toByteArray(); // get byte data
			
			int port = 8888;
			client = new DatagramSocket();
			InetAddress address = InetAddress.getByName("localhost");
			//注意数据包的大小设置
			DatagramPacket packet = new DatagramPacket(data, data.length, address, port);
			System.out.println("start to send data...");
			// send data packet
			client.send(packet);
			System.out.println("finish to send data.");
		} catch (UnknownHostException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		} finally{
			try {
				if (client != null) client.close();
				if (oos != null) oos.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}
}

码农公寓