Open-IM-Server通讯源码

【实例简介】Open-IM-Server通讯源码

Open-IM-Server 是基于 Go 实现的即时通讯 (IM) 项目，从服务端到客户端 SDK 开源即时通讯 (IM) 整体解决方案，可以轻松替代第三方 IM 云服务

【实例截图】

【核心代码】

.
├── Open-IM-Server-main
│   ├── LICENSE
│   ├── README.md
│   ├── cmd
│   │   ├── Open-IM-SDK-Core
│   │   ├── open_im_api
│   │   │   ├── Makefile
│   │   │   ├── docs
│   │   │   │   ├── docs.go
│   │   │   │   ├── swagger.json
│   │   │   │   └── swagger.yaml
│   │   │   └── main.go
│   │   ├── open_im_cms_api
│   │   │   ├── Makefile
│   │   │   └── main.go
│   │   ├── open_im_demo
│   │   │   ├── Makefile
│   │   │   └── main.go
│   │   ├── open_im_msg_gateway
│   │   │   ├── Makefile
│   │   │   └── main.go
│   │   ├── open_im_msg_transfer
│   │   │   ├── Makefile
│   │   │   └── main.go
│   │   ├── open_im_push
│   │   │   ├── Makefile
│   │   │   └── main.go
│   │   ├── rpc
│   │   │   ├── open_im_admin_cms
│   │   │   │   ├── Makefile
│   │   │   │   └── main.go
│   │   │   ├── open_im_auth
│   │   │   │   ├── Makefile
│   │   │   │   └── main.go
│   │   │   ├── open_im_cache
│   │   │   │   ├── Makefile
│   │   │   │   └── main.go
│   │   │   ├── open_im_conversation
│   │   │   │   ├── Makefile
│   │   │   │   └── main.go
│   │   │   ├── open_im_friend
│   │   │   │   ├── Makefile
│   │   │   │   └── main.go
│   │   │   ├── open_im_group
│   │   │   │   ├── Makefile
│   │   │   │   └── main.go
│   │   │   ├── open_im_message_cms
│   │   │   │   ├── Makefile
│   │   │   │   └── main.go
│   │   │   ├── open_im_msg
│   │   │   │   ├── Makefile
│   │   │   │   └── main.go
│   │   │   ├── open_im_office
│   │   │   │   ├── Makefile
│   │   │   │   └── main.go
│   │   │   ├── open_im_organization
│   │   │   │   ├── Makefile
│   │   │   │   └── main.go
│   │   │   ├── open_im_statistics
│   │   │   │   ├── Makefile
│   │   │   │   └── main.go
│   │   │   └── open_im_user
│   │   │       ├── Makefile
│   │   │       └── main.go
│   │   └── test
│   │       └── main.go
│   ├── config
│   │   └── config.yaml
│   ├── deploy
│   │   ├── Makefile
│   │   ├── config.example.yaml
│   │   ├── dockerfiles
│   │   │   ├── Dockerfile.api
│   │   │   ├── Dockerfile.demo
│   │   │   ├── Dockerfile.msg_gateway
│   │   │   ├── Dockerfile.msg_transfer
│   │   │   ├── Dockerfile.push
│   │   │   ├── Dockerfile.rpc_auth
│   │   │   ├── Dockerfile.rpc_friend
│   │   │   ├── Dockerfile.rpc_group
│   │   │   ├── Dockerfile.rpc_msg
│   │   │   ├── Dockerfile.rpc_user
│   │   │   └── Dockerfile.timer_task
│   │   ├── env.yaml
│   │   ├── openim.yaml
│   │   └── readme.md
│   ├── deploy.Dockerfile
│   ├── deploy_k8s
│   │   ├── admin_cms
│   │   │   ├── admin_cms.Dockerfile
│   │   │   └── deployment.yaml
│   │   ├── api
│   │   │   ├── api.Dockerfile
│   │   │   └── deployment.yaml
│   │   ├── auth
│   │   │   ├── auth.Dockerfile
│   │   │   └── deployment.yaml
│   │   ├── build_push_all_images.sh
│   │   ├── cache
│   │   │   ├── cache.Dockerfile
│   │   │   └── deployment.yaml
│   │   ├── cms_api
│   │   │   ├── cms_api.Dockerfile
│   │   │   └── deployment.yaml
│   │   ├── conversation
│   │   │   ├── conversation.Dockerfile
│   │   │   └── deployment.yaml
│   │   ├── demo
│   │   │   ├── demo.Dockerfile
│   │   │   └── deployment.yaml
│   │   ├── friend
│   │   │   ├── deployment.yaml
│   │   │   └── friend.Dockerfile
│   │   ├── group
│   │   │   ├── deployment.yaml
│   │   │   └── group.Dockerfile
│   │   ├── ingress.yaml
│   │   ├── k8s_openim_deploy.md
│   │   ├── kubectl_start_all.sh
│   │   ├── kubectl_stop_all.sh
│   │   ├── message_cms
│   │   │   ├── deployment.yaml
│   │   │   └── message_cms.Dockerfile
│   │   ├── msg
│   │   │   ├── deployment.yaml
│   │   │   └── msg.Dockerfile
│   │   ├── msg_gateway
│   │   │   ├── deployment.yaml
│   │   │   └── msg_gateway.Dockerfile
│   │   ├── msg_transfer
│   │   │   ├── deployment.yaml
│   │   │   └── msg_transfer.Dockerfile
│   │   ├── office
│   │   │   ├── deployment.yaml
│   │   │   └── office.Dockerfile
│   │   ├── organization
│   │   │   ├── deployment.yaml
│   │   │   └── organization.Dockerfile
│   │   ├── path_info.cfg
│   │   ├── push
│   │   │   ├── deployment.yaml
│   │   │   └── push.Dockerfile
│   │   ├── sdk_server
│   │   │   ├── deployment.yaml
│   │   │   └── sdk_server.Dockerfile
│   │   ├── statistics
│   │   │   ├── deployment.yaml
│   │   │   └── statistics.Dockerfile
│   │   └── user
│   │       ├── deployment.yaml
│   │       └── user.Dockerfile
│   ├── docker-compose-mongos.yaml
│   ├── docker-compose-shard-cluster.yaml
│   ├── docker-compose.yaml
│   ├── docs
│   │   ├── Architecture.jpg
│   │   ├── Open-IM-Servers-on-System.png
│   │   ├── Open-IM-Servers-on-docker.png
│   │   ├── Open-IM.png
│   │   ├── Wechat.jpg
│   │   ├── open-im-logo.png
│   │   └── open-im-server.png
│   ├── go.mod
│   ├── go.sum
│   ├── internal
│   │   ├── api
│   │   │   ├── auth
│   │   │   │   └── auth.go
│   │   │   ├── conversation
│   │   │   │   └── conversation.go
│   │   │   ├── friend
│   │   │   │   └── friend.go
│   │   │   ├── group
│   │   │   │   ├── group.go
│   │   │   │   └── super_group.go
│   │   │   ├── manage
│   │   │   │   ├── management_chat.go
│   │   │   │   └── management_user.go
│   │   │   ├── msg
│   │   │   │   ├── del_msg.go
│   │   │   │   ├── get_max_min_seq.go
│   │   │   │   ├── pull_msg.go
│   │   │   │   └── send_msg.go
│   │   │   ├── office
│   │   │   │   ├── tag.go
│   │   │   │   └── work_moments.go
│   │   │   ├── organization
│   │   │   │   └── organization.go
│   │   │   ├── third
│   │   │   │   ├── ali_oss_credential.go
│   │   │   │   ├── aws_storage_credential.go
│   │   │   │   ├── fcm_update_token.go
│   │   │   │   ├── minio_init.go
│   │   │   │   ├── minio_storage_credential.go
│   │   │   │   ├── rtc.go
│   │   │   │   └── tencent_cloud_storage_credential.go
│   │   │   └── user
│   │   │       └── user.go
│   │   ├── cms_api
│   │   │   ├── admin
│   │   │   │   └── admin.go
│   │   │   ├── group
│   │   │   │   └── group.go
│   │   │   ├── message_cms
│   │   │   │   └── message.go
│   │   │   ├── middleware
│   │   │   │   ├── cors.go
│   │   │   │   └── jwt_auth.go
│   │   │   ├── organization
│   │   │   │   └── organization.go
│   │   │   ├── router.go
│   │   │   ├── statistics
│   │   │   │   └── statistics.go
│   │   │   └── user
│   │   │       └── user.go
│   │   ├── demo
│   │   │   └── register
│   │   │       ├── CreateTencentSMSClient_test.go
│   │   │       ├── ali_sms.go
│   │   │       ├── login.go
│   │   │       ├── onboarding_process.go
│   │   │       ├── reset_password.go
│   │   │       ├── send_code.go
│   │   │       ├── set_password.go
│   │   │       ├── sms_interface.go
│   │   │       ├── tencent_sms.go
│   │   │       └── verify.go
│   │   ├── msg_gateway
│   │   │   └── gate
│   │   │       ├── batch_push.go
│   │   │       ├── callback.go
│   │   │       ├── init.go
│   │   │       ├── logic.go
│   │   │       ├── open_im_media
│   │   │       │   └── room.go
│   │   │       ├── relay_rpc_server.go
│   │   │       ├── validate.go
│   │   │       └── ws_server.go
│   │   ├── msg_transfer
│   │   │   └── logic
│   │   │       ├── db.go
│   │   │       ├── init.go
│   │   │       ├── online_history_msg_handler.go
│   │   │       ├── online_msg_to_mongo_handler.go
│   │   │       └── persistent_msg_handler.go
│   │   ├── push
│   │   │   ├── content_struct
│   │   │   │   └── content.go
│   │   │   ├── fcm
│   │   │   │   ├── push.go
│   │   │   │   └── push_test.go
│   │   │   ├── getui
│   │   │   │   └── push.go
│   │   │   ├── jpush
│   │   │   │   ├── common
│   │   │   │   │   └── JGPlatform.go
│   │   │   │   ├── push.go
│   │   │   │   └── requestBody
│   │   │   │       ├── audience.go
│   │   │   │       ├── message.go
│   │   │   │       ├── notification.go
│   │   │   │       ├── options.go
│   │   │   │       ├── platform.go
│   │   │   │       └── pushObj.go
│   │   │   ├── logic
│   │   │   │   ├── callback.go
│   │   │   │   ├── init.go
│   │   │   │   ├── push_handler.go
│   │   │   │   ├── push_rpc_server.go
│   │   │   │   ├── push_to_client.go
│   │   │   │   └── tpns.go
│   │   │   ├── push_interface.go
│   │   │   └── sdk
│   │   │       └── tpns-server-sdk-go
│   │   │           └── go
│   │   │               ├── auth
│   │   │               │   └── auth.go
│   │   │               ├── client
│   │   │               │   └── client.go
│   │   │               ├── common
│   │   │               │   ├── http_helper.go
│   │   │               │   └── json_helper.go
│   │   │               ├── def.go
│   │   │               └── req
│   │   │                   └── req.go
│   │   ├── rpc
│   │   │   ├── admin_cms
│   │   │   │   └── admin_cms.go
│   │   │   ├── auth
│   │   │   │   ├── auth.go
│   │   │   │   └── callback.go
│   │   │   ├── cache
│   │   │   │   └── cache.go
│   │   │   ├── conversation
│   │   │   │   └── conversaion.go
│   │   │   ├── friend
│   │   │   │   ├── callback.go
│   │   │   │   └── friend.go
│   │   │   ├── group
│   │   │   │   ├── callback.go
│   │   │   │   ├── group.go
│   │   │   │   └── super_group.go
│   │   │   ├── message_cms
│   │   │   │   └── message_cms.go
│   │   │   ├── msg
│   │   │   │   ├── callback.go
│   │   │   │   ├── chat.go
│   │   │   │   ├── conversation_notification.go
│   │   │   │   ├── del_msg.go
│   │   │   │   ├── friend_notification.go
│   │   │   │   ├── group_notification.go
│   │   │   │   ├── msg_notification.go
│   │   │   │   ├── msg_status.go
│   │   │   │   ├── organization_notification.go
│   │   │   │   ├── pull_message.go
│   │   │   │   ├── rpcChat.go
│   │   │   │   ├── send_msg.go
│   │   │   │   ├── super_group_notification.go
│   │   │   │   ├── tag_send_msg.go
│   │   │   │   └── work_moments_notification.go
│   │   │   ├── office
│   │   │   │   └── office.go
│   │   │   ├── organization
│   │   │   │   └── organization.go
│   │   │   ├── statistics
│   │   │   │   └── statistics.go
│   │   │   └── user
│   │   │       ├── callback.go
│   │   │       └── user.go
│   │   ├── timed_task
│   │   │   ├── init.go
│   │   │   └── timed_task.go
│   │   └── utils
│   │       ├── callback.go
│   │       ├── cors_middleware_test.go
│   │       ├── get_server_ip_test.go
│   │       ├── id.go
│   │       ├── id_test.go
│   │       ├── image_test.go
│   │       ├── jwt_token_test.go
│   │       ├── md5_test.go
│   │       ├── platform_number_id_to_name_test.go
│   │       └── utils.go
│   ├── pkg
│   │   ├── base_info
│   │   │   ├── auth_api_struct.go
│   │   │   ├── aws_api_struct.go
│   │   │   ├── conversation_api_struct.go
│   │   │   ├── cos_api_struct.go
│   │   │   ├── friend_api_struct.go
│   │   │   ├── group_api_struct.go
│   │   │   ├── manage_api_struct.go
│   │   │   ├── msg.go
│   │   │   ├── office_struct.go
│   │   │   ├── organization_api_struct.go
│   │   │   ├── oss_api_struct.go
│   │   │   ├── public_struct.go
│   │   │   ├── super_group.go
│   │   │   ├── swagger_example.go
│   │   │   ├── third_api_struct.go
│   │   │   ├── user_api_struct.go
│   │   │   └── work_moments_struct.go
│   │   ├── call_back_struct
│   │   │   ├── common.go
│   │   │   ├── group.go
│   │   │   ├── message.go
│   │   │   ├── msg_gateway.go
│   │   │   └── push.go
│   │   ├── cms_api_struct
│   │   │   ├── admin.go
│   │   │   ├── common.go
│   │   │   ├── group.go
│   │   │   ├── message_cms.go
│   │   │   ├── organization.go
│   │   │   ├── statistics.go
│   │   │   └── user.go
│   │   ├── common
│   │   │   ├── config
│   │   │   │   └── config.go
│   │   │   ├── constant
│   │   │   │   ├── constant.go
│   │   │   │   ├── error.go
│   │   │   │   └── platform_number_id_to_name.go
│   │   │   ├── db
│   │   │   │   ├── RedisModel.go
│   │   │   │   ├── batch_insert_chat.go
│   │   │   │   ├── model.go
│   │   │   │   ├── model_struct.go
│   │   │   │   ├── mongoModel.go
│   │   │   │   ├── mysql.go
│   │   │   │   ├── mysql_model
│   │   │   │   │   ├── im_mysql_model
│   │   │   │   │   │   ├── conversation_model.go
│   │   │   │   │   │   ├── demo_model.go
│   │   │   │   │   │   ├── file_model.go
│   │   │   │   │   │   ├── friend_model.go
│   │   │   │   │   │   ├── friend_request_model.go
│   │   │   │   │   │   ├── group_member_model.go
│   │   │   │   │   │   ├── group_model.go
│   │   │   │   │   │   ├── group_request_model.go
│   │   │   │   │   │   ├── message_cms.go
│   │   │   │   │   │   ├── organization_model.go
│   │   │   │   │   │   ├── statistics_model.go
│   │   │   │   │   │   ├── user_black_list_model.go
│   │   │   │   │   │   └── user_model.go
│   │   │   │   │   └── im_mysql_msg_model
│   │   │   │   │       ├── chat_log_model.go
│   │   │   │   │       └── hash_code.go
│   │   │   │   ├── redisModel_test.go
│   │   │   │   └── rocks_cache
│   │   │   │       └── rocks_cache.go
│   │   │   ├── http
│   │   │   │   ├── http_client.go
│   │   │   │   └── http_resp.go
│   │   │   ├── kafka
│   │   │   │   ├── consumer.go
│   │   │   │   ├── consumer_group.go
│   │   │   │   └── producer.go
│   │   │   ├── log
│   │   │   │   ├── es_hk.go
│   │   │   │   ├── file_line_hk.go
│   │   │   │   ├── logrus.go
│   │   │   │   └── time_format.go
│   │   │   ├── multi_terminal_login
│   │   │   │   └── multi_terminal_login.go
│   │   │   ├── token_verify
│   │   │   │   └── jwt_token.go
│   │   │   └── utils
│   │   │       └── utils.go
│   │   ├── grpc-etcdv3
│   │   │   └── getcdv3
│   │   │       ├── pool.go
│   │   │       ├── register.go
│   │   │       └── resolver.go
│   │   ├── proto
│   │   │   ├── admin_cms
│   │   │   │   ├── admin_cms.pb.go
│   │   │   │   └── admin_cms.proto
│   │   │   ├── auth
│   │   │   │   ├── auth.pb.go
│   │   │   │   └── auth.proto
│   │   │   ├── auto_proto.sh
│   │   │   ├── base
│   │   │   │   └── base.proto
│   │   │   ├── cache
│   │   │   │   ├── cache.pb.go
│   │   │   │   └── cache.proto
│   │   │   ├── conversation
│   │   │   │   ├── conversation.pb.go
│   │   │   │   └── conversation.proto
│   │   │   ├── friend
│   │   │   │   ├── friend.pb.go
│   │   │   │   └── friend.proto
│   │   │   ├── group
│   │   │   │   ├── group.pb.go
│   │   │   │   └── group.proto
│   │   │   ├── message_cms
│   │   │   │   ├── message_cms.pb.go
│   │   │   │   └── message_cms.proto
│   │   │   ├── msg
│   │   │   │   ├── msg.pb.go
│   │   │   │   └── msg.proto
│   │   │   ├── office
│   │   │   │   ├── office.pb.go
│   │   │   │   └── office.proto
│   │   │   ├── organization
│   │   │   │   ├── organization.pb.go
│   │   │   │   └── organization.proto
│   │   │   ├── proto_dir.cfg
│   │   │   ├── push
│   │   │   │   ├── push.pb.go
│   │   │   │   └── push.proto
│   │   │   ├── relay
│   │   │   │   ├── relay.pb.go
│   │   │   │   └── relay.proto
│   │   │   ├── rtc
│   │   │   │   ├── rtc.pb.go
│   │   │   │   └── rtc.proto
│   │   │   ├── sdk_ws
│   │   │   │   ├── wrappers.proto
│   │   │   │   ├── ws.pb.go
│   │   │   │   └── ws.proto
│   │   │   ├── statistics
│   │   │   │   ├── statistics.pb.go
│   │   │   │   └── statistics.proto
│   │   │   └── user
│   │   │       ├── user.pb.go
│   │   │       └── user.proto
│   │   ├── statistics
│   │   │   └── statistics.go
│   │   ├── tools
│   │   │   └── tools.go
│   │   └── utils
│   │       ├── base64.go
│   │       ├── cache_delete.go
│   │       ├── cors_middleware.go
│   │       ├── encryption .go
│   │       ├── file.go
│   │       ├── get_server_ip.go
│   │       ├── image.go
│   │       ├── map.go
│   │       ├── strings.go
│   │       ├── time_format.go
│   │       └── utils.go
│   ├── script
│   │   ├── batch_build_all_service.sh
│   │   ├── batch_start_all.sh
│   │   ├── build_all_service.sh
│   │   ├── build_images.sh
│   │   ├── check_all.sh
│   │   ├── demo_svr_start.sh
│   │   ├── docker_check_service.sh
│   │   ├── docker_start_all.sh
│   │   ├── env_check.sh
│   │   ├── function.sh
│   │   ├── mongo-init.sh
│   │   ├── msg_gateway_start.sh
│   │   ├── msg_transfer_start.sh
│   │   ├── path_info.cfg
│   │   ├── push_start.sh
│   │   ├── sdk_svr_start.sh
│   │   ├── start_all.sh
│   │   ├── start_rpc_service.sh
│   │   ├── stop_all.sh
│   │   ├── style_info.cfg
│   │   ├── win_build_all_service.cmd
│   │   └── win_start_all_service.cmd
│   └── test
│       └── mongo
│           ├── cmd
│           │   └── main.go
│           └── mongo_utils.go
└── 好例子网_Open-IM-Server-main.zip

150 directories, 383 files