問題タブ [thrift-protocol]

アプリケーションで Apache Thrift を使用して、複数のマシン間でデータを交換しています。

outspace からデータを受け取り、トランスポート、プロトコルを作成し、受け取ったデータをオブジェクトにデシリアライズします。これが私のコードです：

他のタイプの逆シリアル化は例外をスローするため、バイナリシリアル化されたTCciUserLoginV1.cciUserLoginV1_resultを受け取ります。ただし、 result.Successプロパティの通常の逆シリアル化は、while サイクルの 10 回目の反復後にのみ発生します。whileを使用した理由は何ですか。誰が何が起こっているのか教えてもらえますか?

前もって感謝します。

Thrift を RPC-Protocol として使用して、独自の独自のクローズド ソース言語から Java-Server RPC-Endpoints を呼び出したいと考えています。(いくつかの c ライクなベンダー固有のスクリプト言語)

これに対するバインディングは存在しません。

言語固有のコードを生成する独自のthrift-compiler-pluginsを作成するにはどうすればよいですか? そのためのドキュメントには何も見つかりませんでした。テンプレート言語のようなものはありますか?

ありがとう

2 つの数値を乗算する単純なリサイクル サーバーを作成しようとしています。

私はthriftファイルを次のように書きました：

その後、私は走ってきましたthrift --gen cpp multi.thrift

スケルトン ファイルの名前MultiplicationServer.cppを次のように変更しました。

しかし、ビルドしようとすると、multi_types.h ファイルで次のエラーが発生します: multiple types in one declaration typedef int32_t int 行で multi_types.h ファイルは次のようになります。

その行を削除しようとしましたが、多くのundefined reference toエラーが発生します。

私は何を間違っていますか？

インターネットで検索しましたが、プロキシの背後から Thrift プロトコルを使用する方法についての簡単な手順が見つからないようです。

少し背景を説明すると、Cassandra インスタンス ( http://cassandra.apache.org/ ) を使用して Zipkin トレースを保存する Zipkin インスタンスのセットアップ ( https://github.com/twitter/zipkin ) があります。私たちの意図は、Cassandra へのトレースの書き込みを担当するコレクターと、thrift プロトコルについて交渉することです。

法人の代理人を介して交渉を成功させるには、どのような条件が整っていなければなりませんか? ネゴシエーションを試みるときに特定のプロキシ プロパティを設定するだけでよいのでしょうか?それとも、このネゴシエーションを可能にするために別の設定を行う必要があるのでしょうか?

リソースおよび/または回答に関して、この方向で人々が提供できるヘルプは大歓迎です。

Cassandra のストレス テストに関するヘルプが必要です。datastax Web サイトから cassandra-stress 2.1 ツールをインストールしました。10:1 の比率で 15 スレッドを使用して、読み取りと書き込みのストレス テストを実行したいと考えています。どういうわけかそれを機能させることができません。読み取りと書き込みのテストを別々に行うことができました。

私が使用しているコマンド: ./cassandra-stress mixed ratio(write=1,read=10) n=10000 cl=ONE -port thrift=9160 -schema keyspace="Keyspace1" -mode thrift smart -rate threads>=15 スレッド\<=15 - ノード 192.168.5.10

ポートを 9160 と指定していますが、ネイティブの 9042 ポートを使用しています。

次のエラーが表示されます。

私は一日中苦労していましたが、解決策が見つかりませんでした。

spark-cassandra コネクタを使用して、Spark Streaming アプリケーション経由でリモート Cassandra ノードに接続しようとしていますが、アプリケーションは例外で存在します。どんな助けでも大歓迎です。

最初は問題ないように見えますが (接続は成功し、キースペースがフェッチされます...)、thrift 接続を開こうとすると失敗し、切断されてシャットダウンします。

ポート 9160、9042、および 7000 を開きました。

そしてcassandra.yamlで設定しました

私は何が欠けていますか？

Apache Thrift ライブラリの操作方法を調査しており、送受信操作で seqid 変数が使用されていることがわかりました。しかし、常にゼロに設定されており、変更または使用する場所が見つかりませんでした。とても奇妙です。この変数が倹約にどのような目的で存在するか、誰もが知っていますか?

トピックとしてthrift rpc関数を使いたいのですが、シリアル化にprotobufを使いたいのですが、これを実現しているプロジェクトはありますか? thrift serialization を使用したくない理由は、生成された cpp ファイルを確認した後、_in_place 関数がないことがわかりました。つまり、すべてのメンバーをコピーする必要がありますが、私の場合はすべて持っていますchar* などはすでに他の場所に割り当てられています。

私はかなり単純な Thrift IDL を持っています (図のように 2 つのファイルに分割されています)。

コア。スリフト

加工・倹約

Python Tornado サーバーと Java クライアントを使用しています。コードは次のようになります。

Python サーバー:

Java クライアント:

クライアントがサーバーに正常に接続し、Python PointQueryHandler.getElevations 関数が呼び出されます。ただし、問題は、PointQueryHandler.getElevations への引数が常に空のリストと「未定義」文字列のデフォルト引数であることです。Java クライアントから渡したデータが、何らかの理由でサーバーに到着しません。

何がうまくいかないのですか？

(Thrift バージョン: 0.9.2、Python 2.7.5、JDK 1.7.0_45、プラットフォーム: Windows 7 64 ビット)