간편한 채팅 시스템 - 메시지 전달 서버
기본 코드 논리는 다음과 같습니다.
//
func DealMsg(delivery amqp.Delivery) {
var json = jsoniter.ConfigCompatibleWithStandardLibrary
var transfer1 transfer
err := json.Unmarshal(delivery.Body, &transfer1)
if err != nil {
fmt.Println(err)
return
}
// from := transfer1.From
var data1 Data
// err = json.Unmarshal(transfer1.Data, &data1)
fmt.Println((string(delivery.Body)))
data1 = transfer1.Data
Type := data1.Type
//delivery.Ack(true)
if err != nil {
fmt.Println("json error1:", err)
return
}
switch Type {
case Login, Register, GetMyFriends, LoseConnect, AddUser, OtherAddFriend, ServerUserChangePassword:
//
// fmt.Println(" ")
err = mq.Publish(UserControlServer, delivery.Body)
if err != nil {
fmt.Println("RabbitMq:", err.Error())
}
delivery.Ack(true)
case SendUserMsg, ChatHistory, SendGroupMsg:
//
err = mq.Publish(ChatServer, delivery.Body)
if err != nil {
fmt.Println("RabbitMq:", err.Error())
}
delivery.Ack(true)
case CreateGroup, GetGroupList, GetGroupMember, JoinGroup, OtherAddGroup, ServerInviteUserAddGroup:
//
err = mq.Publish(GroupServer, delivery.Body)
if err != nil {
fmt.Println("RabbitMq:", err.Error())
}
delivery.Ack(true)
}
}
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
간편한 채팅 시스템 - 메시지 전달 서버메시지 전송 서버는 메시지 대기열에서 온 데이터를 받아들여 디코딩, 식별 등을 하고 마지막으로 분류를 나눈다.예를 들어 채팅 시스템은 같은 그룹과 같은 세션의 정보를 같은 그룹 서비스로 전송한다(물론 아직 같은 그룹...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.
좋은 웹페이지 즐겨찾기
