go chat
1.0.0
[TOC]
Используйте программное обеспечение для коммуникационного чата на основе WebSocket.
Кораки в репозитории кода очень легкие. Когда доступ к каждому клиенту доступна, для каждого клиента включена коратика, что может достичь большей параллелистики на автономной машине. В то же время, Go Channel может прекрасно отделить доступ к клиенту, пересылку сообщений и другие операции.
Через Go-Chat вы можете освоить использование канала и выбрать, использование ORM Framework, использование джина веб-структуры, управления конфигурацией, работы журнала и других часто используемых технологий в некоторых проектах.
Основываясь на React, пользовательский интерфейс и основные компоненты используются с дизайном муравья. Это может быть очень удобно создавать интерфейс фронтального интерфейса.
Выбор одной страницы в интерфейсе делает его более удобным для написания интерфейса чата. Например, например, напоминания сообщения, вы можете получать сообщения в одном интерфейсе для напоминаний, и на принятие сообщения не будет влиять на изменение страниц или просмотр другого контента. Передний код репозиторий: https://github.com/kone-net/go-chat-web
Голос, текст, картинки, видео сообщения 
Видеозвонок 
Обмен экранами 
syntax = "proto3" ;
package protocol;
message Message {
string avatar = 1 ; //头像
string fromUsername = 2 ; // 发送消息用户的用户名
string from = 3 ; // 发送消息用户uuid
string to = 4 ; // 发送给对端用户的uuid
string content = 5 ; // 文本消息内容
int32 contentType = 6 ; // 消息内容类型：1.文字 2.普通文件 3.图片 4.音频 5.视频 6.语音聊天 7.视频聊天
string type = 7 ; // 如果是心跳消息，该内容为heatbeat
int32 messageType = 8 ; // 消息类型，1.单聊 2.群聊
string url = 9 ; // 图片，视频，语音的路径
string fileSuffix = 10 ; // 文件后缀，如果通过二进制头不能解析文件后缀，使用该后缀
bytes file = 11 ; // 如果是图片，文件，视频等的二进制
}Из тела сообщений мы видим, что большинство сообщений являются строками или целочисленными типами. Передача может быть выполнена через JSON. Затем зачем выбирать буфер протокола Google для передачи?
Основная конфигурация среды GO ...
Получить бэкэнд код
git clone https://github.com/kone-net/go-chatПерейти к каталогу
cd go-chatЗависимости, необходимые для вытягивания программы
go mod downloadMySQL создает базу данных
CREATE DATABASE chat ;Изменить файл конфигурации базы данных
vim config.toml
[mysql]
host = " 127.0.0.1 "
name = " chat "
password = " root1234 "
port = 3306
table_prefix = " "
user = " root "
修改用户名user，密码password等信息。Создать таблицу
将chat.sql里面的sql语句复制到控制台创建对应的表。Добавить инициализированного пользователя в таблицу пользователя
手动添加用户。Запустите программу
go run cmd/main.goНастройка React Basic Environment, такую как Nodejs ...
Вытащите код
git clone https://github.com/kone-net/go-chat-webПерейти к каталогу
cd go-chat-webОсновные зависимости для установки фронта
npm installЕсли адрес -адрес или номер порта должен быть изменен, адрес бэкэнд должен быть изменен при запуске сервера.
修改src/chat/common/param/Params.jsx里面的IP_PORTПорт запуска по умолчанию для запуска кода переднего интерната 3000
npm startДоступ к передовым порталу
http://127.0.0.1:3000/login
docker build -t konenet/gochat:1.0 .
appName = " chat_room "
[ mysql ]
host = " mysql8 "
name = " go-chat-message "
password = " thepswdforroot "
port = 3306
tablePrefix = " "
user = " root "
[ log ]
level = " debug "
path = " logs/chat.log "
[ staticPath ]
filePath = " web/static/file/ "
[ msgChannelType ]
channelType = " kafka "
kafkaHosts = " kafka:9092 "
kafkaTopic = " go-chat-message " docker-compose up -d
├── Makefile 代码编译，打包，结构化等操作
├── README.md
├── api controller类，对外的接口，如添加好友，查找好友等。所有http请求的入口
│ └── v1
├── assets
│ └── screenshot 系统使用到的资源，markdown用到的截图文件
├── bin 打包的二进制文件
├── chat.sql 整个项目的SQL
├── cmd
│ └── main.go main函数入口，程序启动
├── config
│ └── toml_config.go 系统全局的配置文件配置类
├── config.toml 配置文件
├── deployments
│ └── docker docker构建镜像，docker-compose.yml等文件
├── go.mod
├── go.sum
├── internal
│ ├── dao 数据库
│ ├── kafka kafka消费者和生产者
│ ├── model 数据库模型，和表一一对应
│ ├── router gin和controller类进行绑定
│ ├── server WebSocket中消息的接受和转发的主要逻辑
│ └── service 调用的服务类
├── logs
├── pkg
│ ├── common 常量,工具类
│ ├── errors 封装的异常类
│ ├── global 封装的日志类，使用时不会出现第三方的包依赖
│ └── protocol protoc buffer自动生成的文件,定义的protoc buffer字段
├── test
│ └── kafka_test.go
└── web
└── static 上传的文件等
Выполнить команду Make Mac в корневом каталоге
make build-darwin
实际执行命令是Makefile下的
CGO_ENABLED=0 GOOS=darwin GOARCH=amd64 go build -o bin/chat cmd/main.goLinux
make build
实际执行命令是Makefile下的
CGO_ENABLED=0 GOOS=linux GOARCH=amd64 go build -o bin/chat cmd/main.goЕсли Message.Proto изменяется, вам необходимо перекомпилировать и генерировать соответствующий файл GO. Выполнить в корневом каталоге
make proto
实际执行命令是Makefile下的
protoc --gogo_out=. protocol/ * .protoЕсли прото -файл не установлен локально, вам нужно сначала установить его, в противном случае команда Protoc не будет найдена. Использование gogoprotobuf
Установите файл библиотеки Protobuf
go get github.com/golang/protobuf/protoУстановите проток-Gen-Gogo
go get github.com/gogo/protobuf/protoc-gen-gogoУстановите файл библиотеки gogoprotobuf
go get github.com/gogo/protobuf/protoТест в корневом каталоге:
protoc --gogo_out=. protocol/ * .protoФронт-энд должен установить библиотеку буфера протока
npm install protobufjsГенерировать файл JS Protoc в каталог
npx pbjs -t json-module -w commonjs -o src/chat/proto/proto.js src/chat/proto/ * .proto
src/chat/proto/proto.js 是生成的文件的目录路径及其文件名称
src/chat/proto/ * .proto 是自己写的字段等Этот файл представляет собой карту маршрутизации джина, которая сделает обычные запросы на получение и обновление до подключения к сокету
// router/router.go
func NewRouter () * gin. Engine {
gin . SetMode ( gin . ReleaseMode )
server := gin . Default ()
server . Use ( Cors ())
server . Use ( Recovery )
socket := RunSocekt
group := server . Group ( "" )
{
...
group . GET ( "/socket.io" , socket )
}
return server
}Эта часть обновляет запрос на WebSocket.
// router/socket.go
var upGrader = websocket. Upgrader {
CheckOrigin : func ( r * http. Request ) bool {
return true
},
}
func RunSocekt ( c * gin. Context ) {
user := c . Query ( "user" )
if user == "" {
return
}
log . Info ( "newUser" , zap . String ( "newUser" , user ))
ws , err := upGrader . Upgrade ( c . Writer , c . Request , nil ) //升级协议为WebSocket
if err != nil {
return
}
client := & server. Client {
Name : user ,
Conn : ws ,
Send : make ( chan [] byte ),
}
server . MyServer . Register <- client
go client . Read ()
go client . Write ()
}Это три канала сервера.
// server/server.go
func ( s * Server ) Start () {
log . Info ( "start server" , log . Any ( "start server" , "start server..." ))
for {
select {
case conn := <- s . Register :
log . Info ( "login" , log . Any ( "login" , "new user login in" + conn . Name ))
s . Clients [ conn . Name ] = conn
msg := & protocol. Message {
From : "System" ,
To : conn . Name ,
Content : "welcome!" ,
}
protoMsg , _ := proto . Marshal ( msg )
conn . Send <- protoMsg
case conn := <- s . Ungister :
log . Info ( "loginout" , log . Any ( "loginout" , conn . Name ))
if _ , ok := s . Clients [ conn . Name ]; ok {
close ( conn . Send )
delete ( s . Clients , conn . Name )
}
case message := <- s . Broadcast :
msg := & protocol. Message {}
proto . Unmarshal ( message , msg )
...
...
}
}
}Чтобы загрузить файл буфера обмена, сначала нам нужно получить файл буфера обмена. Как в следующем коде:
bindParse = ( ) => {
document . getElementById ( "messageArea" ) . addEventListener ( "paste" , ( e ) => {
var data = e . clipboardData
if ( ! data . items ) {
return ;
}
var items = data . items
if ( null == items || items . length <= 0 ) {
return ;
}
let item = items [ 0 ]
if ( item . kind !== 'file' ) {
return ;
}
let blob = item . getAsFile ( )
let reader = new FileReader ( )
reader . readAsArrayBuffer ( blob )
reader . onload = ( ( e ) => {
let imgData = e . target . result
// 上传文件必须将ArrayBuffer转换为Uint8Array
let data = {
fromUsername : localStorage . username ,
from : this . state . fromUser ,
to : this . state . toUser ,
messageType : this . state . messageType ,
content : this . state . value ,
contentType : 3 ,
file : new Uint8Array ( imgData )
}
let message = protobuf . lookup ( "protocol.Message" )
const messagePB = message . create ( data )
socket . send ( message . encode ( messagePB ) . finish ( ) )
this . appendImgToPanel ( imgData )
} )
} , false )
}Тот же принцип загрузки голоса
Специальное примечание. Чтобы получить разрешения на обмен вызовом видео, аудио и обмен экранами, это должен быть протокол HTTPS или Localhost, 127.0.0.1 Локальный IP -адрес. Все локальные тесты могут открыть несколько браузеров или использовать эти два локальных IP для выполнения 2TAB -тестов соответственно.
/**
* 当按下按钮时录制视频
*/
dataChunks = [ ] ;
recorder = null ;
startVideoRecord = ( e ) => {
navigator . getUserMedia = navigator . getUserMedia ||
navigator . webkitGetUserMedia ||
navigator . mozGetUserMedia ||
navigator . msGetUserMedia ; //获取媒体对象（这里指摄像头）
let preview = document . getElementById ( "preview" ) ;
this . setState ( {
isRecord : true
} )
navigator . mediaDevices
. getUserMedia ( {
audio : true ,
video : true ,
} ) . then ( ( stream ) => {
preview . srcObject = stream ;
this . recorder = new MediaRecorder ( stream ) ;
this . recorder . ondataavailable = ( event ) => {
let data = event . data ;
this . dataChunks . push ( data ) ;
} ;
this . recorder . start ( 1000 ) ;
} ) ;
}
/**
* 松开按钮发送视频到服务器
* @param {事件} e
*/
stopVideoRecord = ( e ) => {
this . setState ( {
isRecord : false
} )
let recordedBlob = new Blob ( this . dataChunks , { type : "video/webm" } ) ;
let reader = new FileReader ( )
reader . readAsArrayBuffer ( recordedBlob )
reader . onload = ( ( e ) => {
let fileData = e . target . result
// 上传文件必须将ArrayBuffer转换为Uint8Array
let data = {
fromUsername : localStorage . username ,
from : this . state . fromUser ,
to : this . state . toUser ,
messageType : this . state . messageType ,
content : this . state . value ,
contentType : 3 ,
file : new Uint8Array ( fileData )
}
let message = protobuf . lookup ( "protocol.Message" )
const messagePB = message . create ( data )
socket . send ( message . encode ( messagePB ) . finish ( ) )
} )
this . setState ( {
comments : [
... this . state . comments ,
{
author : localStorage . username ,
avatar : this . state . user . avatar ,
content : < p > < video src = { URL . createObjectURL ( recordedBlob ) } controls autoPlay = { false } preload = "auto" width = '200px' /> </ p > ,
datetime : moment ( ) . fromNow ( ) ,
} ,
] ,
} , ( ) => {
this . scrollToBottom ( )
} )
if ( this . recorder ) {
this . recorder . stop ( )
this . recorder = null
}
let preview = document . getElementById ( "preview" ) ;
preview . srcObject . getTracks ( ) . forEach ( ( track ) => track . stop ( ) ) ;
this . dataChunks = [ ]
}
