序列化和反序列化（六）——Java对象的网络传输（一）

清疚 2022-02-15 14:18 230阅读 0赞

Java对象网络传输常用于Java异构平台间数据的交互，Socket和HTTP均可以实现Java对象的网络传输，具体示例如下：

1、Socket实现Java对象的网络传输：

keeper Java工程：

UserInfo类：

package com.jd.vo;
    
    import java.io.Serializable;
    
    public class UserInfo implements Serializable{
    
    	private static final long serialVersionUID = 3103317843148814898L;
    	private int age;
    	private String name;
    
    	public String getAge() {
    		return age;
    	}
    	public void setAge(String age) {
    		this.age = age;
    	}
    	public String getName() {
    		return name;
    	}
    	public void setName(String name) {
    		this.name = name;
    	}
    }

服务器端：

package com.jd.test;
    
    import java.io.ObjectOutput;
    import java.io.ObjectOutputStream;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    import com.jd.vo.UserInfo;
    
    public class Server {
    
    	public static void main(String[] args) {
    		try {
    			ServerSocket serverSocket = new ServerSocket(8080);
    			Socket socket = serverSocket.accept();
    			ObjectOutput objectOutput = new ObjectOutputStream(socket.getOutputStream());
    			
    			UserInfo userInfo = new UserInfo();
    			userInfo.setAge(12);
    			userInfo.setAddress("Tom");
    			
    			objectOutput.writeObject(userInfo);
    			objectOutput.flush();
    			objectOutput.close();
    			serverSocket.close();
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    }

venus Java工程：

UserInfo类：   同keeper工程UserInfo类

客户端：

package com.jd.test;
    
    import java.io.ObjectInput;
    import java.io.ObjectInputStream;
    import java.net.Socket;
    
    public class Client {
    
    	public static void main(String[] args) {
    		try {
    			Socket socket = new Socket("192.168.3.55", 8080);
    			ObjectInput objectInput = new ObjectInputStream(socket.getInputStream());
    			UserInfo userInfo = (UserInfo) objectInput.readObject();
    			objectInput.close();
    			System.out.println(userInfo);
    			socket.close();
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    }

2、HTTP实现Java对象的网络传输：

keeper Java Web工程：

UserInfo类：

服务器端：

package com.jd.servlet;
    
    import java.io.IOException;
    import java.io.ObjectOutput;
    import java.io.ObjectOutputStream;
    
    import javax.servlet.ServletException;
    import javax.servlet.annotation.WebServlet;
    import javax.servlet.http.HttpServlet;
    import javax.servlet.http.HttpServletRequest;
    import javax.servlet.http.HttpServletResponse;
    
    import com.jd.vo.UserInfo;
    
    @WebServlet("/DataServlet")
    public class DataServlet extends HttpServlet {
    	
    	private static final long serialVersionUID = 1L;
      
    	protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
    		ObjectOutput objectOutput = new ObjectOutputStream(response.getOutputStream());
    		
    		UserInfo userInfo = new UserInfo();
    		userInfo.setAge(20);
    		userInfo.setName("Tom");
    		
    		objectOutput.writeObject(userInfo);
    		objectOutput.flush();
    		objectOutput.close();
    	}
    }

venus Java工程：

UserInfo类：同keeper工程UserInfo类

客户端：

package com.jd.test;
    
    import java.io.ObjectInputStream;
    
    import org.apache.http.HttpEntity;
    import org.apache.http.client.methods.CloseableHttpResponse;
    import org.apache.http.client.methods.HttpGet;
    import org.apache.http.impl.client.CloseableHttpClient;
    import org.apache.http.impl.client.HttpClients;
    
    import com.jd.vo.UserInfo;
    
    public class Test {
    
    	public static void main(String[] args) {
    		try {
    			CloseableHttpClient httpclient = HttpClients.createDefault();
    			HttpGet httpGet = new HttpGet("http://127.0.0.1:8080/keeper/DataServlet");// 创建http GET请求
    			CloseableHttpResponse response = httpclient.execute(httpGet);// 执行请求
    			if (response.getStatusLine().getStatusCode() == 200) {// 判断返回状态是否为200
    				HttpEntity entity = response.getEntity();
    				ObjectInputStream in = new ObjectInputStream(entity.getContent());
    				UserInfo userInfo = (UserInfo) in.readObject();
    				System.out.println(userInfo);
    			}
    			response.close();
    			httpclient.close();
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    }