小兔网

HTTP请求式 做过Socket编程的人都知道,当我们设计一个通信协议时,“消息头/消息体”的分割方式是很常用的,消息头告诉对方这个消息是干什么的,消息体告诉对方怎么干。

基于HTTP协议实现RPC和基于TCP协议实现RPC比较:

基于HTTP协议的系统间的 RPC,具有灵活、实现便捷(多种开源的web服务器支持)、开放(国际标准)且天生支持异构平台之间的调用等多个优点,得到了广泛的使用。与之相对应的是TCP协议的实现版本,它效率更高,但实现起来更加复杂,且由于协议和标准的不同,难以进行跨平台和企业间的便捷通信。

HTTP协议实现有其劣势的一面,由于是上层协议,发送包含同等内容的信息,使用HTTP协议传输所占用的字节数肯定要比使用TCP协议传输所占用的字节数更多。因此,同等网络环境下,通过HTTP协议传输相同内容,效率会比TCP协议的数据传输要低,信息传输所占用的时间更长。当然,通过优化代码实现和使用gzip数据压缩,能够缩小这一差距。通过权衡利弊,结合实际环境中其性能对于用户体验的影响来看,基于HTTP协议的RPC还是有很大优势的。

1.基于TCP协议实现RPC

服务接口:

public interface SayHelloService{     public String sayHello(String helloArg);}

服务实现:

public class SayHelloServiceImpl implements SayHelloService {        @Override    public String sayHello(String helloArg) {        if(helloArg.equals("Hello")) {            return "hello";        }else{            return "bye bye";        }    }          }

服务消费者Consumer关键代码:

// 接口名称String interfacename = SayHelloService.class.getName();// 需要远程执行的方法Method method = SayHelloService.class.getMethod("sayHello", java.lang.String.class);// 需要传递到远端的参数Object[] arguments = {"hello"};Socket socket = new Socket("127.0.0.1", 1234);// 将方法名称和参数传递到远端ObjectOutputStream output = new ObjectOutputStream(socket.getOutputStream());output.writeUTF(interfacename); // 接口名称output.writeUTF(method.getName()); // 方法名称output.writeObject(method.getParameterTypes());output.writeObject(arguments);// 从远端读取方法的执行结果ObjectInputStream input = new ObjectInputStream(socket.getInputStream());Object result = input.readObject();

服务提供者Privider关键代码:

ServiceSocket server = new ServerSocket(1234);while(true){    Socket socket = server.accept();    //读取服务信息    ObjectInputStream input = new ObjectInputStream(socket.getInputStream());    String interfacename = input.readUTF();    //接口名称    String methodName = input.readUTF();    // 方法名称    Class<?>[] parameterTypes = (Class<?>[])input.readObject(); //参数类型    Object[] arguments = (Object[]) input.readObject(); //参数对象        // 执行调用    Class serviceinterfaceclass = Class.forName(interfacename);    Object service = service.get(interfacename);    Method method = serviceinterfaceclass.getMethod(methodName, parameterTypes);    Object result = method.invoke(service, arguments);    ObjectOutputStream output = new ObjectOutputStream(socket.getOutputStream());    output.writeObject(result);}

2. 基于HTTP协议的RPC

协议请求定义:

public class Request{        /**    * 协议编码    */    private byte encode;    /**    * 命令    */    private String command;    /**    * 命令长度    */    private int commandLength;}

协议响应的定义:

public class Response {    /**    * 编码    */    private byte encode;    /**    * 响应长度    */    private int responseLength;    /**    * 响应    */    private String response;}

客户端实现关键代码:

// 请求Request request = new Request();request.setCommand("HELLO");request.setCommandLength(request.getCommand().length());request.setEncode(Encode.UTF8.getValue());Socket client = new Socket("127.0.0.1", 4567);OutputStream output = client.getOutputStream();// 发送请求ProtocolUtil.writeRequest(output, request);InputStream input = client.getInputStream();Response = response = ProtocolUtil.readResponse(input);

服务端实现关键代码:

ServerSocket server = new ServerSocket(4567);while(true){    Socket client  = server.accept();       //读取响应数据    InputStream input = client.getInputStream();    Request request = ProtocolUtil.readRequest(input);    OutputStream output = client.getOutputStream();        // 组装响应    Response response = new Response();    response.setEncode(Encode.UTF8.getValue());    if(request.getCommand().equals("HELLO")){       response.setResponse("hello!");     }else {        response.setResponse("bye bye");        }        resposne.setResponseLength(response.getResponse().length());    ProtocolUtil.writeResponse(output, response);}

ProtocolUtil 代码

public class ProtocolUtil {    public static Request readRequest(InputStream input) throws IOException {        //读取编码        byte[] encodeByte = new byte[1];        input.read(encodeByte);        byte encode = encodeByte[0];                //读取命令长度        byte[] commandLengthBytes = new byte[4];        input.read(commandLengthBytes);        int commandLength = ByteUtil.bytes2Int(commandLengthBytes);        //读取命令        byte[] commandBytes = new byte[commandLength];        input.read(commandBytes);        String command = "";        if(Encode.GBK.getValue() == encode){            command = new String(commandBytes, "GBK");        }else{            command = new String(commandBytes, "UTF8");        }        // 组装请求返回        Request request = new Request();        request.setCommand(command);        request.setEncode(encode);        request.setCommandLength(commandLength);        return request;    }    public static void writeResponse(OutputStream output, Response response) throws IOExceptiono{        //将response响应返回给客户端        output.write(response.getEncode());       // output.write(response.getResponseLength());         //直接write一个int类型会截取低8位传输,丢失高8位        output.write(ByteUtil.int2ByteArray(response.getResponseLength()));        if(Encode.GBK.getValue() == resposne.getEncode()){            output.write(response.getResponse().getBytes("GBK"));        }else{            output.write(response.getResponse().getBytes("UTF8"));        }        output.flush();    }}
public static int bytes2Int(byte[] bytes){    int num = bytes[3] & 0xFF;    num |= ((bytes[2] << 8) & 0xFF00;    num |= ((bytes[1] << 16) & 0xFF0000;    num |= ((bytes[0] << 24) & oxFF000000;    return num;}

相关推荐:

HTTP初步注解 - Yitoem

http://windows.php.net/ 和 http://php.net/ 都提供PHP下载,到底什么区别呢?

以上就是如何在远程过程调用(RPC)的知识。速戳>>知识兔学习精品课!