首页 专区 文章 专题 AI工具 学习 编程手册

PHP MySQL jquery HTML CSS
首页 > 后端开发 > php教程

用nginx+uwsgi+redis实现游戏GM聊天功能

风浩大大_9740

风浩大大_9740

2016-08-08

1464人浏览

原创

原始需求

一个客服GM能够加所有游戏服内的玩家为好友，并能进行聊天。具体功能如下：
* GM上、下线
* 加游戏玩家为好友
* 删游戏玩家为好友
* GM发送聊天消息
* 玩家推送聊天消息
额外限定：一个GM账号能够添加多个游戏玩家为好友，而一个游戏玩家只能被一个GM账号添加

需求分析

因为我们游戏内并没有跨服聊天、跨服好友这种功能，而且以后也不会支持，所以让GM在游戏里面创建角色，然后加各个游戏服的玩家进行聊天的方案是无法实施的。 而且GM实际上并不是一个游戏角色，也不用在游戏内创建。
整个的难点是，如何让各个游戏服访问到GM发过来的各种数据，如何将玩家的数据推送给GM。

具体实现

为了实现GM的数据在各个服务器传递，我们采用了一种简单的方案：将GM的数据放在我们的web服务器上，各个游戏服定时从web服务器去拿数据。
这种方案很简单，web服务器与游戏服不用长连接，直接用http的get和post方法就可以拿数据了。整个架构如下:

GM1-------运维聊天服--------游戏web服务器------游戏服务器1--------游戏客户端1||||||GM2游戏服务器2游戏客户端2

这里客服GM1和GM2都用的web界面与游戏客户端聊天。
运维聊天服存在是因为：
* GM的创建需要运维那边的审批。。
* 游戏的web服务器可以进行白名单审查，只有运维聊天服的ip可以访问游戏的web服务器
上图中只有游戏客户端与游戏服务器是采用的tcp长连接，其他都是使用http短连接来实现。
web服务器采用的是nginx，而不是nodejs。nginx方案挺成熟的，而且部署也很容易。
由于，我对python的熟悉程度比lua程度高很多，所以用了uwsgi来做代理，而不是直接用lua来写。
而数据库则采用的redis，redis设置了定时存盘了。数据格式设置可参考我之前提的文章，基本都是
gm:%d:name这种格式，key表示gmx的名字是什么，val表示名字。

实现代码

ARTi.PiCS
ARTi.PiCS

ARTi.PiCS是一款用于生成 AI 头像和风格化个人照片的在线工具。

下载

nginx和uwsgi的配置已略去。因为隐私原因，相关IP已略去，代码里面也有足够的注释，不再赘述:

#encoding: utf-8"""
新功能:
* GM注册
* GM上线
* GM下线
* 加游戏玩家为好友
* 删除游戏好友
* GM推聊天信息
* 玩家推聊天信息

---
消息数据格式为utf-8处理后的base64编码：游戏服和GM发过来的都是base64格式，要注意分隔符没做base64处理
GS只能用get方式推送消息，所以参数用类似于urllib quote（urlencode)进行了封装。运维客户端也用get

一个GM账号能添加多个游戏玩家为好友，而一个游戏玩家只能被一个GM账号添加

"""from config import *
from json import dumps, loads
import base64
import urllib
import urllib2
import copy
import redis


MSG_SEPARATOR = ","#分割信息
MAX_RECV_AMOUNT = 10#每次消息10条吧
MSG_MAX_LEN = 500#消息不弄太长了CONTENT_TYPE = [("Content-Type","text/html")]
HTTP_STATUS = {
    200: "200 OK",
    404: "404 Not Found",
}

GAME_SERVER_INFO_URL = "http://xxxxxyyyyy"ROLE_INFO_URL = "http://xxyyy?uid=%s&hostnum=%s"red = redis.StrictRedis(host=REDIS.HOST, port=REDIS.PORT, db=REDIS.DB)

#游戏服务器IP白名单ifnot globals().has_key("gServerIP"):
    gServerIP = {}
    res_data = urllib2.urlopen(GAME_SERVER_INFO_URL)
    res = res_data.read()
    res_list = res.split("\n")
    for val in res_list: 
        ifnot val:
            continue
        _, port, ip, _  = val.split(" ") 
        gServerIP[ip] = port

gGMIP = {
        "xxxxyyyy" : 1,
}

defis_gm_account_exist(account_id):if red.get("gm_account:%s:name" % account_id):
        return1return0defis_inter_server(hostnum):if ( int(hostnum) >= 1000 ):
        return0return1defcheck_is_int(account_id):try:
        int(account_id)
    except:
        return HTTP_STATUS[200], CONTENT_TYPE, dumps({"res": 0, "errno": -1})
    return ()

#gm client ensures the id is uniquedefgm_create_account(env, params):
    account_id, account_name  = params["gm_account"], urllib.unquote(params["gm_name"]) 
    check_res = check_is_int(account_id)
    if check_res: return check_res
    if is_gm_account_exist(account_id):
        return HTTP_STATUS[200], CONTENT_TYPE, dumps({"res": 0, "errno": 1}) #1 the role exists
    red.set("gm_account:%s:name" % account_id, account_name)
    red.sadd("gm_online_list", account_id)
    return HTTP_STATUS[200], CONTENT_TYPE, dumps({"res": 1})

#check paramdefgm_add_friend(env, params):
    var = gm_account, hostnum, usernum = params["gm_account"], params["host"], params["uid"]
    for num in var:
        check_res = check_is_int(num)
        if check_res: return check_res
    ifnot is_gm_account_exist(gm_account):
        return HTTP_STATUS[200], CONTENT_TYPE, dumps({"res": 0, "errno": 2}) #2 the role doesn't existif ( red.get("gs_usernum:%s:friend" % usernum) ):
        return HTTP_STATUS[200], CONTENT_TYPE, dumps({"res": 0, "errno": 3}) #3 the usernum has gotten a friend#内服计费没存数据，就不处理了ifnot is_inter_server(hostnum):
        http_res_data = urllib2.urlopen(ROLE_INFO_URL % (usernum, hostnum))
        res = loads(http_res_data.read())
        if (type(res) != type({})) or (res.get("code", 0) != 1):
            return HTTP_STATUS[200], CONTENT_TYPE, dumps({"res": 0, "errno": 4}) #4 the uid doesn't exist    red.sadd("gm_account:%s:friend" % gm_account, usernum) #两边都处理下    red.sadd("gs_hostnum:%s" % hostnum, usernum) #记录该服务器的所有玩家
    red.set("gs_usernum:%s:hostnum" % usernum, hostnum) #该玩家的信息
    red.set("gs_usernum:%s:friend" % usernum, gm_account) #一个玩家只能被一个gm添加为好友    red.sadd("apply_frd_list", usernum) #usernum will be added 
    red.hdel("remove_frd_list", usernum) #信息残留return HTTP_STATUS[200], CONTENT_TYPE, dumps({"res": 1}) 

defgm_remove_friend(env, params):
    account_id, uid = params["gm_account"], params["uid"]
    ifnot is_gm_account_exist(account_id):
        return HTTP_STATUS[200], CONTENT_TYPE, dumps({"res": 0, "errno": 2}) #2 the role doesn't existif red.get("gs_usernum:%s:friend" % uid) != account_id:
        return HTTP_STATUS[200], CONTENT_TYPE, dumps({"res": 0, "errno": 5})  # the usernum has friend but isn't the gmifnot red.srem("gm_account:%s:friend" % account_id, uid):
        return HTTP_STATUS[200], CONTENT_TYPE, dumps({"res": 0, "errno": 4})  # the usernum is not a friend of the gm    hostnum = red.get("gs_usernum:%s:hostnum" % uid)
    red.delete("gs_usernum:%s:hostnum" % uid) #合服考虑，如果合服了GM手动删除这个玩家吧
    red.srem("gs_hostnum:%s" % hostnum, uid)

    red.delete("gs_usernum:%s:friend" % uid) 
    red.hset("remove_frd_list", uid, hostnum) #uid的信息已经丢失，先额外保存下hostnum信息
    red.srem("apply_frd_list", uid) #信息残留return HTTP_STATUS[200], CONTENT_TYPE, dumps({"res": 1}) 

#GM账号很少defgm_online(env, params):
    account_id = params["gm_account"] #可能客户端bug没发下线，直接sadd吧ifnot is_gm_account_exist(account_id):
        return HTTP_STATUS[200], CONTENT_TYPE, dumps({"res": 0, "errno": 2}) #2 the role doesn't exist
    red.sadd("gm_online_list", account_id)
    return HTTP_STATUS[200], CONTENT_TYPE, dumps({"res": 1})

defgm_offline(env, params):
    account_id = params["gm_account"]
    ifnot red.srem("gm_online_list", account_id):
        return HTTP_STATUS[200], CONTENT_TYPE, dumps({"res": 0})
    return HTTP_STATUS[200], CONTENT_TYPE, dumps({"res": 1})

#存在usernum上,gs_msg和gm_msgdefgm_sendmsg(env, params):
    account_id, uid, msg = params["gm_account"], params["uid"], urllib.unquote(params["msg"]) #只能向好友发ifnot red.sismember("gm_account:%s:friend" % account_id, uid):
        return HTTP_STATUS[200], CONTENT_TYPE, dumps({"res": 0, "errno": 4})  # the usernum is not a friend of the gmif red.get("gs_usernum:%s:friend" % uid) != account_id:
        return HTTP_STATUS[200], CONTENT_TYPE, dumps({"res": 0, "errno": 5})  # the usernum has friend but isn't the gm or doesn't have
    red.lpush("gs_usernum:%s:msg_from_gm" % uid, msg)
    red.sadd("gm_newmsg_list", uid) #gs get msg from this setreturn HTTP_STATUS[200], CONTENT_TYPE, dumps({"res": 1})

#gm轮训所有的，他那边还有个服务器...#{gm_account:{"uid": msg, "uid2": msg2}}defgm_receivemsg(env, params):
    user_set = copy.copy(red.smembers("gs_newmsg_list"))
    msg_data = {}
    for uid in user_set:
        gm_account = red.get("gs_usernum:%s:friend" % uid)
        ifnot gm_account: #理论上是不会continue
        msg_list = pop_msg(uid, "msg_from_gs")
        send_msg = MSG_SEPARATOR.join(msg_list)
        ifnot send_msg:
            continueifnot gm_account in msg_data:
            msg_data[gm_account] = []
        msg_data[gm_account].append({"uid" : uid, "msg" : send_msg})
        #red.srem("gs_newmsg_list", uid)return HTTP_STATUS[200], CONTENT_TYPE, dumps({"res": 1, "data": base64.b64encode(dumps(msg_data))})

defpop_msg(uid, msg_type):
    msg_list = []
    msg_key = "gs_usernum:%s:%s" % (uid, msg_type)
    msg_len = min(MAX_RECV_AMOUNT, red.llen(msg_key))
    for i in xrange(msg_len):
        piece_msg = red.rpop(msg_key)
        msg_list.append(piece_msg)
    return msg_list

#---------------------GS----------------------#apply and removedefget_frd_relation(env, params):
    host = params["host"]

    apply_user_set = copy.copy(red.smembers("apply_frd_list"))
    apply_data = {}  #{"res":1 "data":base64({uid: gm_account})}for uid in apply_user_set:
        hostnum = red.get("gs_usernum:%s:hostnum" % uid)
        if hostnum != host:
            continue
        account_id = red.get("gs_usernum:%s:friend" % uid)
        ifnot account_id: #error continue        apply_data[uid] = [account_id, red.get("gm_account:%s:name" % account_id)]
        red.srem("apply_frd_list", uid)


    del_user_list = red.hkeys("remove_frd_list")
    remove_list = []
    for uid in del_user_list:
        hostnum = red.hget("remove_frd_list", uid)
        if hostnum != host:
            continue
        remove_list.append(uid)
        red.hdel("remove_frd_list", uid)
    return HTTP_STATUS[200], CONTENT_TYPE, dumps({"res": 1, "apply_data": base64.b64encode(dumps(apply_data)), "remove_data": base64.b64encode(dumps(remove_list))})   

defgs_sendmsg(env, params):
    uid, msg = params["uid"], urllib.unquote(params["msg"])
    ifnot red.get("gs_usernum:%s:friend" % uid):
        return HTTP_STATUS[200], CONTENT_TYPE, dumps({"res": 0, "errno": 5})  # the usernum has friend but isn't the gm or doesn't have
    red.lpush("gs_usernum:%s:msg_from_gs" % uid, msg)
    red.sadd("gs_newmsg_list", uid) #gm get msg from this setreturn HTTP_STATUS[200], CONTENT_TYPE, dumps({"res": 1})

defgs_receivemsg(env, params):
    host = params["host"]
    user_set = copy.copy(red.smembers("gm_newmsg_list"))
    total_msg_list = [] 
    for uid in user_set:
        hostnum = red.get("gs_usernum:%s:hostnum" % uid)
        if hostnum != host:
            continue
        msg_list = pop_msg(uid, "msg_from_gm")
        user_msg = MSG_SEPARATOR.join(msg_list)
        ifnot user_msg:
            continue
        msg_data = {
                "uid"   : uid,
                "msg"   : user_msg,
        }
        total_msg_list.append(msg_data)
    return HTTP_STATUS[200], CONTENT_TYPE, dumps({"res": 1, "data": base64.b64encode(dumps(total_msg_list))})

defget_online_list(env, params):
    host = params["host"]
    send_list = []
    online_list = red.smembers("gm_online_list")
    for account_id in online_list:
        frd_set = red.smembers("gm_account:%s:friend" % account_id)
        for uid in frd_set:
            if red.get("gs_usernum:%s:hostnum" % uid) == host:
                send_list.append(account_id) #只有这个服务器有gm的好友，才通知breakreturn HTTP_STATUS[200], CONTENT_TYPE, dumps({"res": 1, "data": base64.b64encode(dumps(send_list))})

#get:  action=create&gm_account&gm_name  创建账号#get:  action=add&gm_account&host&uid 添加好友#get:  action=del&gm_account&uid 删除好友#get:  action=online&gm_account上线#get:  action=offline&gm_account 下线#get:  action=send&gm_account&uid&msg 发送消息#get:  action=receive 轮训消息
GM_FUNC = {
        "create"    : gm_create_account,
        "add"       : gm_add_friend,
        "del"       : gm_remove_friend,
        "online"    : gm_online,
        "offline"   : gm_offline,
        "send"      : gm_sendmsg,
        "receive"   : gm_receivemsg,
}

defhandle_gm_ticket(env, params):ifnot gGMIP.get(env["REMOTE_ADDR"], 0):
        return HTTP_STATUS[200], CONTENT_TYPE, "%s has no access to the website" % env["REMOTE_ADDR"]
    func = GM_FUNC.get(params["action"], None)
    ifnot func:
        return HTTP_STATUS[404], CONTENT_TYPE, "err action %s" % params["action"]
    return func(env, params)

#get    action=relation&host#get    action=send&uid&msg#get    action=receive&host#get    action=online&host        
GS_FUNC = { 
        "relation"  : get_frd_relation,
        "send"      : gs_sendmsg,
        "receive"   : gs_receivemsg,
        "online"    : get_online_list,
}

defhandle_gs_ticket(env, params):ifnot gServerIP.get(env["REMOTE_ADDR"], 0):
        return HTTP_STATUS[200], CONTENT_TYPE, "%s has no access to the website" % env["REMOTE_ADDR"]
    func = GS_FUNC.get(params["action"], None)
    ifnot func:
        return HTTP_STATUS[404], CONTENT_TYPE, "err action %s" % params["action"]
    return func(env, params)

版权声明：本文为博主原创文章，未经博主允许不得转载。

以上就介绍了用nginx+uwsgi+redis实现游戏GM聊天功能，包括了方面的内容，希望对PHP教程有兴趣的朋友有所帮助。

相关文章

LiblibAI API如何调用现成工作流

Java 单元测试怎么使用 @ParameterizedTest 参数化测试

TP6和TP8在数据库连接池配置上有什么不同

如何在SQL存储过程中利用sp executesql实现参数化查询

Iris框架怎么自定义上下文对象
在线游戏
在线游戏

海量精品小游戏合集，无需安装即点即玩，休闲益智、动作闯关应有尽有，秒开即玩，轻松解压，快乐停不下来

下载

相关标签:

本站声明：本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系admin@php.cn

上一篇：Nginx 的线程池与性能剖析

下一篇：1亿条数据在PHP中实现Mysql数据库分表100张

热门AI工具

更多
立刻MV

立刻MV

Hot VibeKnow

VibeKnow

Hot 超级简历WonderCV

超级简历WonderCV

Hot 讯飞绘文

讯飞绘文

Hot Lovart

Lovart

Hot 豆包大模型

豆包大模型

 DeepSeek

DeepSeek

 咔片AIPPT

咔片AIPPT

Hot

相关专题

更多
Aionclaw智能助手介绍
Aionclaw智能助手介绍

本专题汇总了AionClaw（AI龙虾助手）的功能介绍与在线使用入口。AionClaw是杭州趣猿人工智能有限公司推出的桌面级AI智能体，能直接在电脑上读写文件、运行脚本、操作浏览器，自动交付Word、PPT、Excel等成品。

2026.09.20

0

13

AionClaw AI智能体与电脑自动化任务执行功能使用教程
AionClaw AI智能体与电脑自动化任务执行功能使用教程

AionClaw专题整理AI智能体与电脑自动化相关功能使用教程，涵盖安装部署、AI任务执行、Skills技能、文件处理、浏览器控制、电脑操作、持久记忆、聊天工具连接以及办公、编程和内容创作等功能，帮助用户快速掌握AionClaw的实际使用方法。

2026.09.20

0

15

AI视频生成软件推荐
AI视频生成软件推荐

本专题汇总了当前主流的AI视频生成软件推荐与排行榜单，涵盖seko、AniShort、剧云、Lovart、LiblibAI及立刻mv等热门工具。同时整理了各软件在文生视频、图生视频、时长限制、画质表现及免费额度等方面的差异对比，助您快速选对适合创作需求的AI视频生成工具。

2026.09.16

180

9

ai生成视频的工具免费版合集
ai生成视频的工具免费版合集

本专题汇总了当前免费AI生成视频工具的排行榜与推荐清单，涵盖seko、讯飞智作、AniShort及剧云、Lovart等多模型集成平台。同时整理了各工具的免费额度、输出时长、水印政策及适用场景差异，助您快速选择合适工具开启AI视频创作。

2026.09.16

60

10

Pandas时间序列分析与可视化报表
Pandas时间序列分析与可视化报表

本专题整理Pandas日期转换、时间索引、重采样、滚动窗口、时区处理、plot绘图、Styler表格样式和报表输出方法。

2026.09.16

80

23

Pandas数据筛选索引与清洗处理
Pandas数据筛选索引与清洗处理

本专题整理Pandas中的loc、iloc、条件筛选、query查询、缺失值处理、重复值删除、类型转换和字符串列清洗方法。

2026.09.16

60

25

Pandas数据读取导入与文件导出处理
Pandas数据读取导入与文件导出处理

本专题整理Pandas读取CSV、Excel、JSON、SQL、Parquet等文件的方法，以及to_csv、to_excel、to_sql和to_parquet等常用数据导出流程。

2026.09.16

40

27

GDB怎么设置断点
GDB怎么设置断点

本专题介绍GDB按照函数名、源代码行号和文件位置设置断点的方法，详细说明run、continue、next、step等命令的配合使用，帮助定位程序崩溃、逻辑异常及代码未按预期执行的问题。

2026.09.11

380

28

GDB怎么查看变量值
GDB怎么查看变量值

本专题介绍GDB调试过程中查看变量值的具体方法，涵盖局部变量、函数参数、数组、结构体和指针内容查询，同时整理变量持续显示、格式化输出及无法读取变量时的排查思路。

2026.09.11

120

22

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

相关下载

更多
MDPHP(麦迪php框架系统)1.1
PHP 多国语言框架2.0
ujframe简单快速PHP开发框架1.0
php轻量型框架1.0
MyQEE开源PHP多项目及模块化开发框架3.0 RC2
php开源学习型框架CMVC1.2.0
PHP框架Kohana3.3.1

精品课程

更多
热门推荐
/
最新课程
phpStudy极速入门视频教程
phpStudy极速入门视频教程

共6课时 | 54.6万人学习

独孤九贱(4)_PHP视频教程
独孤九贱(4)_PHP视频教程

共89课时 | 133万人学习

PHP实战天龙八部之仿爱奇艺电影网站
PHP实战天龙八部之仿爱奇艺电影网站

共49课时 | 82万人学习

最新文章

更多
如何在 PHP 中按相同日期合并订单商品数组（支持多产品共用日期）
HTTP 301重定向陷阱：URL末尾斜杠引发的API请求失效问题
如何在 PHP 中不依赖第三方库生成符合标准的 HS512 JWT
如何在 PHP 中按相同日期合并订单商品数组（支持多产品共用日期的聚合）
如何在 PHP 中按相同日期合并订单商品数组（支持多产品共用日期场景）
怎样在ClearLinux配置Laravel10
为什么CodeIgniter连接数据库总是提示连接失败
怎样在PopOS22.04运行Laravel11
Laravel6x如何配置phpredis环境变量
PHP8.3会话如何配置会话ID长度