HTTP請(qǐng)求式做過(guò)Socket程式設(shè)計(jì)的人都知道，當(dāng)我們?cè)O(shè)計(jì)一個(gè)通訊協(xié)定時(shí)，「訊息標(biāo)頭/訊息體」的分割方式是很常用的，訊息頭告訴對(duì)方這個(gè)訊息是乾什麼的，訊息體告訴對(duì)方怎麼幹。

基於HTTP協(xié)定實(shí)現(xiàn)RPC與基於TCP協(xié)定實(shí)現(xiàn)RPC比較：

? ? ? ?基於HTTP協(xié)定的系統(tǒng)間的RPC，具有靈活、實(shí)現(xiàn)便利（多種開源的web伺服器支援）、開放（國(guó)際標(biāo)準(zhǔn)）且天生支援異質(zhì)平臺(tái)之間的呼叫等多個(gè)優(yōu)點(diǎn)，都得到了廣泛的使用。與之相對(duì)應(yīng)的是TCP協(xié)定的實(shí)現(xiàn)版本，它效率更高，但實(shí)現(xiàn)起來(lái)更加複雜，且由於協(xié)定和標(biāo)準(zhǔn)的不同，難以進(jìn)行跨平臺(tái)和企業(yè)間的便捷通訊。

? ? ? ?HTTP協(xié)定實(shí)現(xiàn)有其劣勢(shì)的一面，由於是上層協(xié)議，發(fā)送包含同等內(nèi)容的信息，使用HTTP協(xié)議傳輸所佔(zhàn)用的字節(jié)數(shù)肯定要比使用TCP協(xié)議傳輸所佔(zhàn)用的字節(jié)數(shù)更多。因此，在同等網(wǎng)路環(huán)境下，透過(guò)HTTP協(xié)定傳輸相同內(nèi)容，效率會(huì)比TCP協(xié)定的資料傳輸?shù)?，訊息傳輸所?zhàn)用的時(shí)間也更長(zhǎng)。當(dāng)然，透過(guò)優(yōu)化程式碼實(shí)現(xiàn)和使用gzip資料壓縮，能夠縮小這一差距。透過(guò)權(quán)衡利弊，結(jié)合實(shí)際環(huán)境中其效能對(duì)於使用者體驗(yàn)的影響來(lái)看，基於HTTP協(xié)定的RPC還是有很大的優(yōu)勢(shì)。

1.基於TCP協(xié)定實(shí)作RPC

服務(wù)介面：

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

服務(wù)實(shí)作：

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

服務(wù)消費(fèi)者Consumer關(guān)鍵程式碼：

// 接口名稱
String interfacename = SayHelloService.class.getName();
// 需要遠(yuǎn)程執(zhí)行的方法
Method method = SayHelloService.class.getMethod("sayHello", java.lang.String.class);
// 需要傳遞到遠(yuǎn)端的參數(shù)
Object[] arguments = {"hello"};
Socket socket = new Socket("127.0.0.1", 1234);
// 將方法名稱和參數(shù)傳遞到遠(yuǎn)端
ObjectOutputStream output = new ObjectOutputStream(socket.getOutputStream());
output.writeUTF(interfacename); // 接口名稱
output.writeUTF(method.getName()); // 方法名稱
output.writeObject(method.getParameterTypes());
output.writeObject(arguments);

// 從遠(yuǎn)端讀取方法的執(zhí)行結(jié)果
ObjectInputStream input = new ObjectInputStream(socket.getInputStream());
Object result = input.readObject();

服務(wù)提供者Privider關(guān)鍵代碼：

ServiceSocket server = new ServerSocket(1234);
while(true){
    Socket socket = server.accept();

    //讀取服務(wù)信息
    ObjectInputStream input = new ObjectInputStream(socket.getInputStream());
    String interfacename = input.readUTF();    //接口名稱
    String methodName = input.readUTF();    // 方法名稱
    Class<?>[] parameterTypes = (Class<?>[])input.readObject(); //參數(shù)類型
    Object[] arguments = (Object[]) input.readObject(); //參數(shù)對(duì)象
    
    // 執(zhí)行調(diào)用
    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協(xié)定的RPC

協(xié)定請(qǐng)求定義：

public class Request{
    
    /**
    * 協(xié)議編碼
    */
    private byte encode;

    /**
    * 命令
    */
    private String command;

    /**
    * 命令長(zhǎng)度
    */
    private int commandLength;
}

協(xié)定回應(yīng)的定義：

public class Response {

    /**
    * 編碼
    */
    private byte encode;

    /**
    * 響應(yīng)長(zhǎng)度
    */
    private int responseLength;

    /**
    * 響應(yīng)
    */
    private String response;
}

客戶端實(shí)作關(guān)鍵程式碼：

// 請(qǐng)求
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();

// 發(fā)送請(qǐng)求
ProtocolUtil.writeRequest(output, request);
InputStream input = client.getInputStream();
Response = response = ProtocolUtil.readResponse(input);

服務(wù)端實(shí)作關(guān)鍵程式碼：

ServerSocket server = new ServerSocket(4567);
while(true){
    Socket client  = server.accept();
   
    //讀取響應(yīng)數(shù)據(jù)
    InputStream input = client.getInputStream();
    Request request = ProtocolUtil.readRequest(input);
    OutputStream output = client.getOutputStream();
    
    // 組裝響應(yīng)
    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];
        
        //讀取命令長(zhǎng)度
        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");
        }

        // 組裝請(qǐng)求返回
        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響應(yīng)返回給客戶端
        output.write(response.getEncode());
       // output.write(response.getResponseLength()); 
        //直接write一個(gè)int類型會(huì)截取低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;
}

?相關(guān)推薦：

# HTTP初步註解- Yitoem

http://windows.php.net/ 和?http://php.net/ 都提供PHP下載，到底什麼差別呢？

以上是如何在遠(yuǎn)端過(guò)程中呼叫（RPC）的詳細(xì)內(nèi)容。更多資訊請(qǐng)關(guān)注PHP中文網(wǎng)其他相關(guān)文章！