オブジェクトメッセージ

基本メッセージオブジェクト

メッセージオブジェクトには互換性がありますmq各モジュールを使用してカスタム メッセージ処理システムを構築できます。作成方法は次のとおりです。

1
2
var mq = require("mq");
var m = new mq.Message();

相続関係

コンストラクタ

Message

メッセージオブジェクトコンストラクター

1
new Message();

絶え間ない

TEXT

テキストタイプを表すメッセージタイプ1を指定します。

1
const Message.TEXT = 1;

---

BINARY

バイナリ型を表すメッセージ タイプ 2 を指定します。

1
const Message.BINARY = 2;

メンバーのプロパティ

value

文字列、メッセージの基本的な内容

1
String Message.value;

---

params

NArray、メッセージの基本パラメータ

1
readonly NArray Message.params;

---

type

整数、メッセージタイプ

1
Integer Message.type;

---

data

値。メッセージのデータをクエリします。この属性は、コンテンツ タイプに応じて異なるデータを返します。テキストの場合は、テキストが返されます。jsonいつ戻るjsonそれ以外の場合はバイナリを返します

1
readonly Value Message.data;

---

body

SeekableStream、メッセージのデータ部分を含むストリーム オブジェクト

1
SeekableStream Message.body;

---

length

Long、メッセージデータ部分の長さ

1
readonly Long Message.length;

---

stream

Stream、メッセージ readFrom をクエリするときのストリーム オブジェクト

1
readonly Stream Message.stream;

---

lastError

文字列、クエリ、およびメッセージ処理の最後のエラーを設定します

1
String Message.lastError;

メンバー関数

read

指定したサイズのデータ​​をストリームから読み取ります。このメソッドは、本体の対応するメソッドのエイリアスです。

1
Buffer Message.read(Integer bytes = -1) async;

呼び出しパラメータ:

• bytes: 整数。読み取られるデータの量を指定します。デフォルトでは、ランダムなサイズのデータ​​ ブロックが読み取られます。読み取られるデータのサイズはデバイスによって異なります。

返される結果:

• Bufferは、ストリームから読み取られたデータを返します。読み取るデータがない場合、または接続が中断された場合は、null が返されます。

---

readAll

ストリームから残りのデータをすべて読み取ります。このメソッドは、本体の対応するメソッドのエイリアスです。

1
Buffer Message.readAll() async;

返される結果:

• Bufferは、ストリームから読み取られたデータを返します。読み取るデータがない場合、または接続が中断された場合は、null が返されます。

---

write

指定されたデータを書き込みます。このメソッドは、本体内の対応するメソッドのエイリアスです。

1
Message.write(Buffer data) async;

呼び出しパラメータ:

• data:Buffer、書き込まれるデータが与えられると、

---

json

指定されたデータを JSON エンコードで書き込みます

1
Value Message.json(Value data);

呼び出しパラメータ:

• data: 書き込まれるデータの値

返される結果:

• Value、このメソッドはデータを返しません

---

メッセージ内のデータを JSON エンコードとして解析します

1
Value Message.json();

返される結果:

• Value、解析された結果を返します

---

pack

によるmsgpackエンコーディングは指定されたデータを書き込みます

1
Value Message.pack(Value data);

呼び出しパラメータ:

• data: 書き込まれるデータの値

返される結果:

• Value、このメソッドはデータを返しません

---

によるmsgpackメッセージ内のデータのエンコードと解析

1
Value Message.pack();

返される結果:

• Value、解析された結果を返します

---

end

現在のメッセージ処理の終了を設定します。Chainプロセッサは後続のトランザクションを続行しません

1
Message.end();

---

isEnded

現在のメッセージが終了したかどうかを問い合わせます

1
Boolean Message.isEnded();

返される結果:

• Boolean、終了すると true を返します

---

clear

メッセージの内容をクリアする

1
Message.clear();

---

sendTo

フォーマットされたメッセージを指定されたストリーム オブジェクトに送信します

1
Message.sendTo(Stream stm) async;

呼び出しパラメータ:

• stm:Stream、フォーマットされたメッセージを受信するストリーム オブジェクトを指定します。

---

readFrom

指定されたキャッシュ ストリーム オブジェクトからフォーマットされたメッセージを読み取り、設定されたオブジェクトを解析します

1
Message.readFrom(Stream stm) async;

呼び出しパラメータ:

• stm:Stream、フォーマットされたメッセージを読み取るためのストリーム オブジェクトを指定します

---

toString

オブジェクトの文字列表現を返します。通常、「[Native Object]」が返されます。オブジェクトは、独自の特性に従って再実装できます。

1
String Message.toString();

返される結果:

• String、オブジェクトの文字列表現を返します。

---

toJSON

オブジェクトの JSON 形式表現を返します。通常は、オブジェクトによって定義された読み取り可能なプロパティのコレクションを返します。

1
Value Message.toJSON(String key = "");

呼び出しパラメータ:

• key: 文字列、使用されません

返される結果:

• Value、シリアル化可能な JSON を含む値を返します