thrift筆記----大體上thrift知識

来源:https://www.cnblogs.com/tk55/archive/2020/04/11/12680073.html
-Advertisement-
Play Games

thrift類似java裡面的socket和sockchannel中server和client通信 thrift最重要的是跨語言，裡面提供了序列化和反序列化、json和實體對象等方法 Apache Thrift軟體框架（用於可擴展的跨語言服務開發）將軟體堆棧與代碼生成引擎結合在一起，以構建可在C++ ...


thrift類似java裡面的socket和sockchannel中server和client通信

thrift最重要的是跨語言，裡面提供了序列化和反序列化、json和實體對象等方法

Apache Thrift軟體框架（用於可擴展的跨語言服務開發）將軟體堆棧與代碼生成引擎結合在一起，
以構建可在C++, Java, Python, PHP, Ruby, Erlang, Perl, Haskell, C#, Cocoa, JavaScript, Node.js, Smalltalk, OCaml and Delphi 
等語言

裡面大概方法

圖片轉其他地方

 

 

 數據類型

bool：布爾值，對應 Java 的 boolean
byte：8 位有符號整數，對應 Java 的 byte
i16：16 位有符號整數，對應 Java 的 short
i32：32 位有符號整數，對應 Java 的 int
i64：64 位有符號整數，對應 Java 的 long
double：64 位浮點數，對應 Java 的 double
string：文本或二進位字元串，對應 Java 的 String
struct：定義公共的對象，在 Java 中是一個 JavaBean
list：對應 Java 的 ArrayList
set：對應 Java 的 HashSet
map：對應 Java 的 HashMap
exception：對應 Java 的 Exception
service：service 類型可以被繼承
enum：枚舉類型

 

maven導入jar

<dependency>
  <groupId>org.apache.thrift</groupId>
  <artifactId>libthrift</artifactId>
  <version>0.13.0</version>
</dependency>

 

 

新建thrift文件

（thrift命名例如UserService.thrift）

namespace java com.test.libthrift.demo2
struct UserInfo{
     1:optional i32 id;
     2:optional string key;
     3:optional string value;
}
service UserService {
  bool isLogin(1:string username,2:string password)
  UserInfo setUserInfo(1:UserInfo user)
  string setStr(1:string str)
  list<UserInfo> setuserInfos(1:list<UserInfo> li)
}

生成介面

給客戶端庫和所編寫的伺服器使用，複製到服務端和客戶端項目里

例如

thrift -r -gen java UserService.thrift

thrift --gen <語言> <Thrift 文件名>

 

序列化

                    TSerializer serializer = new TSerializer(new TSimpleJSONProtocol.Factory());
                    UserInfo user = new UserInfo();
                    user.setId(100);
                    user.setKey("key01");
                    user.setValue("value值");
                    String json = serializer.toString(user);

反序列

        TDeserializer deserializer = new TDeserializer(new TSimpleJSONProtocol.Factory());
        UserInfo base =new UserInfo();
        deserializer.deserialize(base, str,"UTF-8");

 

服務端實現介面

package com.test.libthrift.demo2;

import java.util.List;

import org.apache.thrift.TDeserializer;
import org.apache.thrift.TException;
import org.apache.thrift.protocol.TSimpleJSONProtocol;

public class UserServiceImpl implements UserService.Iface{

    @Override
    public boolean isLogin(String username, String password) throws TException {
        // TODO Auto-generated method stub
        System.out.println("收到客戶端："+username+"---"+password);
        if(username==null ||password==null) return false;
        if("lyx".equals(username)&&"123456".equals(password)) return true;
        
        return false;
    }

    @Override
    public UserInfo setUserInfo(UserInfo user) throws TException {
        // TODO Auto-generated method stub
        System.out.println("收到客戶端UserInfo:"+user.toString());
        return user;
    }

    @Override
    public String setStr(String str) throws TException {
        // TODO Auto-generated method stub
        System.out.println("收到客戶端str:"+str);

        TDeserializer deserializer = new TDeserializer(new TSimpleJSONProtocol.Factory());
        UserInfo base =new UserInfo();
        deserializer.deserialize(base, str,"UTF-8");
        System.out.println("反序列化:"+base.toString());
        return str;
    }

    @Override
    public List<UserInfo> setuserInfos(List<UserInfo> li) throws TException {
        // TODO Auto-generated method stub
        System.out.println("收到客戶端LIST:");
        for(UserInfo u : li){
            System.out.println(u.toString());
        }
        return li;
    }


}
View Code

服務端啟動服務

package com.test.libthrift.demo2.server;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TCompactProtocol;
import org.apache.thrift.server.TNonblockingServer;
import org.apache.thrift.server.TServer;
import org.apache.thrift.server.TSimpleServer;
import org.apache.thrift.server.TThreadedSelectorServer;
import org.apache.thrift.transport.TFramedTransport;
import org.apache.thrift.transport.TNonblockingServerSocket;
import org.apache.thrift.transport.TServerSocket;
import org.apache.thrift.transport.TTransportException;

import com.test.libthrift.demo2.UserService;
import com.test.libthrift.demo2.UserServiceImpl;

public class uServerSocket {

    public static void main(String[] args) throws TTransportException {
        // TODO Auto-generated method stub
/*        TServerSocket serversocket = new TServerSocket(20000);
        //服務的介面
        TServer.Args arg = new TServer.Args(serversocket);
        arg.processor(new UserService.Processor<UserService.Iface>(new UserServiceImpl()));
        arg.protocolFactory(new TBinaryProtocol.Factory());
        TServer server = new TSimpleServer(arg);
        server.serve();*/
        
        // 非阻塞方式  
        TNonblockingServerSocket serversocket = new TNonblockingServerSocket(20000);
        //服務的介面
//        TNonblockingServer.Args
        TThreadedSelectorServer.Args arg = new TThreadedSelectorServer.Args(serversocket);
        arg.processor(new UserService.Processor<UserService.Iface>(new UserServiceImpl()));
        // 設置協議工廠，高效率的、密集的二進位編碼格式進行數據傳輸協議
        arg.protocolFactory(new TCompactProtocol.Factory());
        // 設置傳輸工廠，使用非阻塞方式，按塊的大小進行傳輸，類似於Java中的NIO
        arg.transportFactory(new TFramedTransport.Factory());
        // 多個線程，主要負責客戶端的IO處理
        arg.selectorThreads(2);
        // 工作線程池
        ExecutorService pool = Executors.newFixedThreadPool(3);
        
        arg.executorService(pool);
        TThreadedSelectorServer server = new TThreadedSelectorServer(arg);
        System.out.println("Starting server .....");
        server.serve();
        
    }

}
View Code

 

客戶端連接服務端

package com.test.libthrift.demo2.client;

import java.io.ByteArrayOutputStream;
import java.io.UnsupportedEncodingException;
import java.util.ArrayList;
import java.util.List;

import org.apache.thrift.TBase;
import org.apache.thrift.TException;
import org.apache.thrift.TSerializer;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TCompactProtocol;
import org.apache.thrift.protocol.TJSONProtocol;
import org.apache.thrift.protocol.TProtocol;
import org.apache.thrift.protocol.TSimpleJSONProtocol;
import org.apache.thrift.transport.TFastFramedTransport;
import org.apache.thrift.transport.TIOStreamTransport;
import org.apache.thrift.transport.TMemoryInputTransport;
import org.apache.thrift.transport.TSocket;
import org.apache.thrift.transport.TTransport;
import org.apache.thrift.transport.TTransportException;

import com.test.libthrift.demo2.UserInfo;
import com.test.libthrift.demo2.UserService;

public class uSocketClient {

/*    public static void main(String[] args) {
        // TODO Auto-generated method stub
        TTransport socket = new TSocket("127.0.0.1", 20000, 30000);
        // 協議要和服務端一致
        TProtocol  protocol = new TBinaryProtocol(socket);
        UserService.Client client = new UserService.Client(protocol);
        try {
            socket.open();
        } catch (TTransportException e1) {
            // TODO Auto-generated catch block
            e1.printStackTrace();
        }
        try {
            boolean b = client.isLogin("", "");
            System.out.println("收到服務端："+b);
            if(b ==false){
                try {
                    Thread.sleep(12000);
                    
                } catch (InterruptedException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                b = client.isLogin("lyx", "123456");
                System.out.println("收到服務端："+b);
            }
        } catch (TException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally {
              System.out.println("close");
              socket.close();
        }
        
        
    }*/
  
    
    
    public static void main(String[] args) {
        // TODO Auto-generated method stub
        TTransport socket =new TFastFramedTransport(  new TSocket("127.0.0.1", 20000, 30000));
        // 協議要和服務端一致
        TProtocol  protocol = new TCompactProtocol(socket);
        UserService.Client client = new UserService.Client(protocol);
        try {
            socket.open();
        } catch (TTransportException e1) {
            // TODO Auto-generated catch block
            e1.printStackTrace();
        }
        try {
            boolean b = client.isLogin("", "");
            System.out.println("收到服務端："+b);
            if(b ==false){
                try {
                    Thread.sleep(12000);
                    
                } catch (InterruptedException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                b = client.isLogin("lyx", "123456");
                System.out.println("收到服務端："+b);
                
                try {
                    Thread.sleep(10000);
                    System.out.println("發送user");
                    TSerializer serializer = new TSerializer(new TSimpleJSONProtocol.Factory());
                    UserInfo user = new UserInfo();
                    user.setId(100);
                    user.setKey("key01");
                    user.setValue("value值");
                    String json = serializer.toString(user);
                    System.out.println("json String:"+json);
                    System.out.println("發送str json");
                    client.setStr(json);
                    System.out.println("發送usrInfo");
                    client.setUserInfo(user);
                    List<UserInfo> list =new ArrayList<UserInfo>();
                    for(int i=1;i<101;i++){
                        user = new UserInfo();
                        user.setId(i);
                        user.setKey("key"+i);
                        user.setValue("value值"+i);
                        list.add(user);
                    }
                    client.setuserInfos(list);
                    
                    try {
                        socket.write(json.getBytes("UTF-8"));
                    } catch (UnsupportedEncodingException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                    System.out.println("發送user結束");
                } catch (InterruptedException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                
            }
        } catch (TException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally {
              System.out.println("close");
              socket.close();
        }
        
        
    }
    

}
View Code

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • javascript正則表達式：匹配所有html標簽【轉】
    在面試的過程中遇到一個這樣的題目： 比如有一段HTML字元串： 其實匹配html標簽的正則表達式很短，如下： ]+ 就這樣，沒了？是的。你驚訝嗎？ 這個正則表達式也是收集於網路，但是我可以看懂，首先，html標簽肯定是以符號結束（不管是不是自閉合），只是中間有點糾結，可能有字元，數字，引號，換行符— ...
  • 在vue項目中封裝echarts的正確姿勢
    為什麼需要封裝echarts 每個開發者在製作圖表時都需要從頭到尾書寫一遍完整的option配置，十分冗餘 在同一個項目中，各類圖表設計十分相似，甚至是相同，沒必要一直做重覆工作 可能有一些開發者忘記考慮echarts更新數據的特性，以及視窗縮放時的適應問題。這樣導致數據更新了echarts視圖卻沒 ...
  • 前端工程師需要具備哪些基本素質?
    眾所周知，前端工程師的首要工作就是開發用戶界面，因此我們可以把前端工程師看做是用戶體驗的把控者。正所謂責任越大能力越大，前端工程師的工作內容也讓這一崗位需要具備更多的能力，除了精通HTML、CSS這樣的基礎知識，對前端要求更高的其實是非技術因素。下麵我們一起來看看前端工程師需要具備哪些基本素質。 1 ...
  • react axios 跨域訪問一個或多個功能變數名稱
    1.react + axios 跨域訪問一個功能變數名稱 配置非常簡單，只需要在當前的 package.json 文件裡面配置： "proxy":"http://iot-demo-web-dev.autel.com", //當然，這裡是一個假地址 像這樣： 這樣跨域便完成了，當然，也可以像網上那樣，多幾段代 ...
  • Jquery鍵盤輸入
    根據上上篇的鍵盤ui界面我添加了一個輸入框讓鍵盤有了輸入效果如下 界面代碼可以去上上篇看： https://www.cnblogs.com/2979100039-qq-con/p/12641603.html 這那個代碼基礎上加了一個輸入框，在把鍵盤縮放0.7倍就可以了 接下重點是js代碼同樣用的是j ...
  • 9.使用CSS樣式，自己製作單選框樣式和選中功能
    自己製作單選框樣式： <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <titl ...
  • JavaScript 開發必須掌握技能（一）
    申明：本文轉載至：https://github.com/dawn-plex/translate/blob/master/articles/5-Tips-to-Write-Better-Conditionals-in-JavaScript.md 感謝作者，感謝分享 原文地址：5 Tips to Wri ...
  • JavaScript 中的三位一體
    最近看到一個有意思的圖片，包含了鮮為人知的秘密。。。 先看看這張有意思的圖片。 圖左應該講的是基督教中的三位一體。翻譯成中文如下。 當然這不是我們的重點，我們的重點在右邊這個圖。講的是js中相等操作。 是js中的寬鬆相等(loose equals)。 是嚴格相等(strict equals)。 這兩 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類