flutter mqtt chat client

채팅 목적으로 MQTT를 통해 구축 된 프로토콜 인 MQCHAT의 Flutter Client.

브로커는 HiveMQ 채팅 확장을 먼저 설치해야합니다.

특징

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. Chatmarkers를 들어보십시오

 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 : 사용자에게 패키지에 대해 더 자세히 알려주십시오 : 더 많은 정보를 찾을 수있는 위치, 패키지에 기여하는 방법, 문제를 제출하는 방법, 패키지 작성자가 기대할 수있는 응답 등.