import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
public class ReceiveDemo {
public static void main(String[] args) throws IOException, ClassNotFoundException {
//1.创建接收端Socket对象
DatagramSocket send=new DatagramSocket(6666);
//2.创建数据包接收对象
byte[] buf=new byte[1024];
DatagramPacket datagramPacket=new DatagramPacket(buf,buf.length);
send.receive(datagramPacket);
//3.解析数据包,并把数据写入对象
byte[] data=datagramPacket.getData();
ByteArrayInputStream bis=new ByteArrayInputStream(data);
ObjectInputStream ois=new ObjectInputStream(bis);
Student stu1=(Student)ois.readObject();
System.out.println(stu1.getName()+":"+stu1.getAge());
//4.释放资源
ois.close();
bis.close();
send.close();
}
}
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.ObjectOutputStream;
import java.net.*;
public class SendDemo {
public static void main(String[] args) throws IOException {
//1.创建发送端Socket对象
DatagramSocket receive=new DatagramSocket(6666);
//2.创建要发送的对象
Student stu1=new Student("张三",18);
//3.创建输出流写入对象
//ByteArrayOutputStream 对byte类型数据进行写入的类 相当于一个中间缓冲层,将类写入到文件等其他outputStream。
//此类实现一个字节输出流、其中数据被写入到字节数组中,缓冲区在数据写入时会自动增长,关闭该流无效,关闭此流后调用方法不会有异常
ByteArrayOutputStream bos=new ByteArrayOutputStream();
ObjectOutputStream oos=new ObjectOutputStream(bos);
oos.writeObject(stu1);
byte[] buf=bos.toByteArray();
//System.out.println(InetAddress.getLocalHost().getHostAddress()); 获取本机真实IP
//4.创建数据包并发送资源
DatagramPacket datagramPacket=new DatagramPacket(buf,buf.length,new InetSocketAddress("172.20.2.154",6666));
receive.send(datagramPacket);
//5.释放资源
bos.close();
oos.close();
receive.close();
}
}
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)