12345678910111213141516171819 |
- 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();
- }
- }
|