flutter mqtt chat client
1.0.0
MQTTを介してチャット目的で構築されたプロトコルであるMQChatのフラッタークライアント。
ブローカーは、最初にHIVEMQチャットエクステンションをインストールする必要があります。
MQTTをチャットプロトコルとして使用して、必要なすべての機能をサポートする最新のチャットアプリケーションを作成します。これはMQChatのフラッタークライアントです。
パッケージflutter-mqchatをインストールします。
flutter pub add flutter-mqchat
完全で豊富な例は/exampleフォルダーにあります。
既存のアカウントを使用してユーザーログイン：
bool connected = await ChatApp . instance () ! .clientHandler. connect (
host : "broker.url.com" ,
username : "[email protected]" ,
password : "user_pass" );ログインが成功した後、MQTTクライアントは更新を受け取ります。受信する最初の更新は、プロファイルの詳細、ユーザーがメンバーである部屋、継続的な招待状とメッセージです（メッセージアーカイブがブローカーによってサポートされている場合）。
ChatApp . instance () ! .archiveHandler. getUser (). listen ((user) {
//insert/update user to database
});ログインしたユーザーが部屋に追加されるたびに（または部屋の詳細が変更されました）、部屋の詳細が会話ストリームに追加されます。
ChatApp . instance () ! .archiveHandler. getAllConversations (). listen ((rooms) {
//insert/update rooms on the Database
}); ChatApp . instance () ! .messageReader. getChatMessages (). listen ((message) {
var dbMessage = message. toDbMessage ();
// insert the message to the database
// send chatmarker if the message is not mine
}); ChatApp . instance () !
.messageReader
. getChatMarkerMessages ()
. listen ((markerMessage) {
String messageId = markerMessage.referenceId;
if (markerMessage.status == ChatMarker .displayed) {
//update the database record
} else if (markerMessage.status == ChatMarker .delivered) {
//update the database record
}
}); ChatApp . instance () !
.invitationHandler
. newInvitationsStream ()
. listen ((invitation) {
if (invitation.type == MessageType . EventInvitationRequest ) {
//new invitation request
//insert invitation record to the database, notify the user
}
if (invitation.type == MessageType . EventInvitationResponseAccept || invitation.type == MessageType . EventInvitationResponseReject ) {
//responded to invitation, update the local record and wait the server to sync the new contact (if accepted).
//Do not insert a room, the user will receive a new room details triggered by getAllConversations()
}
});これを使用して、ユーザーが送信した招待状を聴きます。それはかもしれません：
ChatApp . instance () !
.invitationHandler
. invitationUpdatesStream ()
. listen ((invitation) {
if (invitation.invitationMessageType == InvitationMessageType . INFO ) {
//update the invitation record to be confirmed
}
else if (invitation.invitationMessageType == InvitationMessageType . ERROR ) {
//notify the user, and delete the record in inserted
}
}); ChatMessage newMessage = ChatMessage (
id : "generated_random_id" ,
type : MessageType . ChatText ,
text : "Hello there" ,
roomId : "[room_id]" ,
fromId : "[my_id]" , //optional
sendTime : DateTime . now ().millisecondsSinceEpoch,
fromName : "[my_name]" ); ChatApp . instance () !
.messageSender
. sendChatMessage (newMessage, "[room_id]" ); ChatMessage replyToMessage = ...; //the message to reply to
ChatApp . instance () !
.messageSender
. replyToMessage (replyToMessage, newMessage, widget.contactChat.roomId); ChatApp . instance () ! .messageSender. sendFileChatMessage (
type : MessageType . ChatImage , //for example
fileLocalPath : path,
room : "[room_id]" ); ChatApp . instance () !
.eventsSender
. sendIsTyping ( true , "[room_id]" ); ChatApp . instance () ! .messageReader. getTypingMessages (). listen ((event) {
//using event.roomId and event.isTyping and event.fromId, update the ui state
}); ChatApp . instance () !
.eventsSender
. sendInvitation ( "[invitee_username]" , "[invitation_random_id]" );TODO：パッケージの詳細については、詳細情報を見つける場所、パッケージへの貢献方法、問題を提出する方法、パッケージ著者に期待できる応答などをユーザーに伝えます。
