package cn.hhj.rpcsend;

import cn.hhj.constant.Constant;
import cn.hhj.request.RpcRequest;

import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;

public class RpcNetTransport {
    public Object send(RpcRequest request) throws Exception {
        Socket socket = new Socket(Constant.SERVER_HOST,Constant.SERVER_PORT);
        ObjectOutputStream os = new ObjectOutputStream(socket.getOutputStream());
        os.writeObject(request);
        os.flush();
        ObjectInputStream is = new ObjectInputStream(socket.getInputStream());
        return is.readObject();
    }
}