flutter mqtt chat client

MQChat的Flutter客户端，该协议是通过MQTT构建的，用于聊天目的。

经纪人应首先安装HiveMQ Chat-Extension。

特征

使用MQTT作为聊天协议，创建一个支持所有必要功能的现代聊天应用程序。这是MQCHAT的狂潮客户。

• 登录
• 发送/接收消息（文本，图像，视频，位置，文档，联系消息）
• 发送文件
• 打字指标
• 在场
• 小组聊天
• 私人聊天邀请

入门

安装软件包flutter-mqchat ：

 flutter pub add flutter-mqchat

用法

可以在/example文件夹中找到一个完整而丰富的示例。

1。登录

使用现有帐户的用户登录：

 bool connected = await ChatApp . instance () ! .clientHandler. connect (
        host : "broker.url.com" ,
        username : "[email protected]" ,
        password : "user_pass" );

成功登录后，MQTT客户端将收到更新。要收到的第一个更新是个人资料详细信息，用户是持续邀请和消息的房间（如果经纪人支持消息归档）。

2。听我的个人资料更改

 ChatApp . instance () ! .archiveHandler. getUser (). listen ((user) {
      //insert/update user to database
    });

3。听房间

每当将用户登录的用户添加到房间（或更改房间的详细信息）时，将添加房间详细信息。

 ChatApp . instance () ! .archiveHandler. getAllConversations (). listen ((rooms) {
      //insert/update rooms on the Database
    });

4。听新消息

 ChatApp . instance () ! .messageReader. getChatMessages (). listen ((message) {
      var dbMessage = message. toDbMessage ();
      // insert the message to the database
      // send chatmarker if the message is not mine
    });

5。听聊天标记

 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
      }
    });

6。听新的聊天邀请

 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()
          }
    });

7.收听Invitatioin更新

我们使用它来收听用户发送的邀请。可能是：

• 信息：当收到邀请发送的确认时
• 错误：有错误时（找不到用户）

 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
      }
    });

8。发送短信

 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]" );

8.1发送消息作为常规消息

 ChatApp . instance () !
          .messageSender
          . sendChatMessage (newMessage, "[room_id]" );

8.2发送消息作为回复另一条消息

 ChatMessage replyToMessage = ...; //the message to reply to
ChatApp . instance () !
          .messageSender
          . replyToMessage (replyToMessage, newMessage, widget.contactChat.roomId);

9。发送文件消息

 ChatApp . instance () ! .messageSender. sendFileChatMessage (
          type : MessageType . ChatImage , //for example
          fileLocalPath : path,
          room : "[room_id]" );

10。发送键入指示器

 ChatApp . instance () !
          .eventsSender
          . sendIsTyping ( true , "[room_id]" );

11。听打字指示灯

 ChatApp . instance () ! .messageReader. getTypingMessages (). listen ((event) {
    //using event.roomId and event.isTyping and event.fromId, update the ui state
    
    });

12。发送新的聊天邀请

 ChatApp . instance () !
        .eventsSender
        . sendInvitation ( "[invitee_username]" , "[invitation_random_id]" );

附加信息

TODO：向用户提供更多有关包装的信息：在哪里可以找到更多信息，如何为包装贡献，如何提交问题，他们可以从包装作者那里获得什么响应等等。