객체메시지

기본 메시지 객체

메시지 객체는 다음과 호환됩니다.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

스트림에서 지정된 크기의 데이터를 읽습니다. 이 메서드는 해당 body 메서드의 별칭입니다.

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

호출 매개변수:

• bytes: 정수, 읽을 데이터의 양을 지정합니다. 기본값은 임의 크기의 데이터 블록을 읽는 것입니다. 읽는 데이터의 크기는 장치에 따라 다릅니다.

결과 반환:

• Buffer, 스트림에서 읽은 데이터를 반환하며, 읽을 데이터가 없거나 연결이 중단된 경우 null이 반환됩니다.

---

readAll

스트림에서 나머지 데이터를 모두 읽습니다. 이 메서드는 해당 body 메서드의 별칭입니다.

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을 포함하는 값을 반환합니다.