大家好，我是彬哥，本节给大家讲下LollipopGov1.0.20190102版本游戏服务器globla服务器，抛砖引玉了，主要是针对Go语言游戏服务器Global服务器处理。

package main

import (

"LollipopGo/LollipopGo/conf"

"LollipopGo/LollipopGo/error"

"LollipopGo/LollipopGo/log"

"LollipopGo/LollipopGo/match"

"Proto"

"Proto/Proto2"

"flag"

"fmt"

"net/rpc"

"net/rpc/jsonrpc"

"strings"

"time"

"LollipopGo/LollipopGo/util"

"LollipopGo/ReadCSV"

"LollipopGo/LollipopGo/player"

"code.google.com/p/go.net/websocket"

)

/*

匹配、活动服务器

1 匹配玩家活动

*/

var addrG = flag.String("addrG", "127.0.0.1:8888", "http service address")

var Conn *websocket.Conn

var ConnRPC *rpc.Client

func init() {

if !initGateWayNet() {

fmt.Println("链接 gateway server 失败!")

return

}

fmt.Println("链接 gateway server 成功!")

initNetRPC()

return

}

func initNetRPC() {

client, err := jsonrpc.Dial("tcp", service)

if err != nil {

log.Debug("dial error:", err)

//panic("dial RPC Servre error")

return

}

ConnRPC = client

}

func initGateWayNet() bool {

fmt.Println("用户客户端客户端模拟！")

url := "ws://" + *addrG + "/GolangLtd"

conn, err := websocket.Dial(url, "", "test://golang/")

if err != nil {

fmt.Println("err:", err.Error())

return false

}

Conn = conn

go GameServerReceiveG(Conn)

initConn(Conn)

return true

}

// 处理数据

func GameServerReceiveG(ws *websocket.Conn) {

for {

var content string

err := websocket.Message.Receive(ws, &content)

if err != nil {

fmt.Println(err.Error())

continue

}

fmt.Println(strings.Trim("", "\""))

fmt.Println(content)

content = strings.Replace(content, "\"", "", -1)

contentstr, errr := base64Decode([]byte(content))

if errr != nil {

fmt.Println(errr)

continue

}

go SyncMeassgeFunG(string(contentstr))

}

}

// 链接分发 处理

func SyncMeassgeFunG(content string) {

var r Requestbody

r.req = content

if ProtocolData, err := r.Json2map(); err == nil {

HandleCltProtocolG(ProtocolData["Protocol"], ProtocolData["Protocol2"], ProtocolData)

} else {

log.Debug("解析失败：", err.Error())

}

}

// 主协议处理

func HandleCltProtocolG(protocol interface{}, protocol2 interface{}, ProtocolData map[string]interface{}) {

// defer func() { // 必须要先声明defer，否则不能捕获到panic异常

// if err := recover(); err != nil {

// strerr := fmt.Sprintf("%s", err)

// //发消息给客户端

// ErrorST := Proto2.G_Error_All{

// Protocol: Proto.G_Error_Proto, // 主协议

// Protocol2: Proto2.G_Error_All_Proto, // 子协议

// ErrCode: "80006",

// ErrMsg: "亲，您发的数据的格式不对！" + strerr,

// }

// // 发送给玩家数据

// fmt.Println("Global server的主协议!!!", ErrorST)

// }

// }()

// 协议处理

switch protocol {

case float64(Proto.G_GameGlobal_Proto):

{ // Global Server 主要协议处理

fmt.Println("Global server 主协议!!!")

HandleCltProtocol2Glogbal(protocol2, ProtocolData)

}

default:

panic("主协议：不存在！！！")

}

return

}

// 子协议的处理

func HandleCltProtocol2Glogbal(protocol2 interface{}, ProtocolData map[string]interface{}) {

switch protocol2 {

case float64(Proto2.GW2G_ConnServerProto2):

{ // 网关返回数据

fmt.Println("gateway server 返回给global server 数据信息！！！")

}

case float64(Proto2.G2GW_PlayerEntryHallProto2):

{

G2GW_PlayerEntryHallProto2Fucn(Conn, ProtocolData)

}

case float64(Proto2.G2GW_PlayerMatchGameProto2):

{

fmt.Println("玩家请求玩家匹配！")

G2GW_PlayerMatchGameProto2Fucn(Conn, ProtocolData)

}

case float64(Proto2.GW2G_PlayerQuitMatchGameProto2):

{

fmt.Println("玩家主动退出匹配！")

G2GW_PlayerQuitMatchGameProto2Fucn(Conn, ProtocolData)

}

default:

panic("子协议：不存在！！！")

}

return

}

// 玩家主动退出匹配

func G2GW_PlayerQuitMatchGameProto2Fucn(conn *websocket.Conn, ProtocolData map[string]interface{}) {

if ProtocolData["OpenID"] == nil {

panic("玩家主动退出匹配!")

return

}

StrOpenID := ProtocolData["OpenID"].(string)

// 玩家主动退出

match.SetQuitMatch(StrOpenID)

// 发送消息

data_send := &Proto2.G2GW_PlayerQuitMatchGame{

Protocol: Proto.G_GameGlobal_Proto,

Protocol2: Proto2.G2GW_PlayerQuitMatchGameProto2,

OpenID: StrOpenID,

ResultID: 0,

}

PlayerSendToServer(conn, data_send)

return

}

// 玩家匹配

func G2GW_PlayerMatchGameProto2Fucn(conn *websocket.Conn, ProtocolData map[string]interface{}) {

if ProtocolData["OpenID"] == nil ||

ProtocolData["RoomID"] == nil ||

ProtocolData["Itype"] == nil {

panic("选择游戏对战类型协议参数错误！")

return

}

StrOpenID := ProtocolData["OpenID"].(string)

StrRoomID := ProtocolData["RoomID"].(string) // 匹配数据

StrItype := ProtocolData["Itype"].(string) // 1 是正常匹配 2 是快速匹配

// 数据

data_send := &Proto2.GW2G_PlayerMatchGame{

Protocol: Proto.G_GameGlobal_Proto, // 游戏主要协议

Protocol2: Proto2.GW2G_PlayerMatchGameProto2,

OpenID: StrOpenID, // 玩家唯一标识

// RoomUID: 0,

// MatchPlayer: nil,

// ChessBoard: {{}, {}, {}, {}},

ResultID: 0,

}

if match.GetMatchQueue(StrOpenID) {

data_send.ResultID = Error.IsMatch

PlayerSendToServer(conn, data_send)

return

}

match.SetMatchQueue(StrOpenID)

if StrItype == "2" { //快速匹配

PlayerSendToServer(conn, data_send)

return

}

data := conf.RoomListDatabak[StrRoomID]

fmt.Println("针对某房间ID去获取，相应的数据的", conf.RoomListDatabak, data.NeedLev, StrRoomID)

dataplayer := DB_Save_RoleSTBak(StrOpenID)

match.Putdata(dataplayer)

s := string([]byte(data.NeedLev)[2:])

if util.Str2int_LollipopGo(s) > dataplayer.Lev {

data_send.ResultID = Error.Lev_lack

PlayerSendToServer(conn, data_send)

return

} else if util.Str2int_LollipopGo(data.NeedPiece) > dataplayer.CoinNum {

data_send.ResultID = Error.Coin_lack

PlayerSendToServer(conn, data_send)

return

}

if len(match.MatchData) > 1 {

dar :=

data_send.MatchPlayer = dar

fmt.Println(data_send)

PlayerSendToServer(conn, data_send)

match.DelMatchQueue(StrOpenID)

} else {

go PlayerMatchTime(conn, StrOpenID, data_send)

}

return

}

func PlayerMatchTime(conn *websocket.Conn, OpenID string, data_send *Proto2.GW2G_PlayerMatchGame) {

icount := 0

for {

select {

case

{

fmt.Println(icount)

if icount >= 30 {

PlayerSendToServer(conn, data_send)

return

}

if len(match.MatchData_Chan) > 1 {

dar :=

data_send.MatchPlayer = dar

fmt.Println(data_send)

PlayerSendToServer(conn, data_send)

match.DelMatchQueue(OpenID)

return

}

icount++

}

}

}

}

// 保存数据都DB 人物信息

func DB_Save_RoleSTBak(openid string) *player.PlayerSt {

args := player.PlayerSt{

OpenID: openid,

}

var reply *player.PlayerSt

// 异步调用【结构的方法】

if ConnRPC != nil {

// ConnRPC.Call("Arith.GetPlayerST2DB", args, &reply) 同步调用

divCall := ConnRPC.Go("Arith.GetPlayerST2DB", args, &reply, nil)

replyCall :=

_ = replyCall.Reply

} else {

fmt.Println("ConnRPC == nil")

}

return reply

}

func G2GW_PlayerEntryHallProto2Fucn(conn *websocket.Conn, ProtocolData map[string]interface{}) {

StrUID := ProtocolData["UID"].(string)

StrOpenID := ProtocolData["OpenID"].(string)

StrPlayerName := ProtocolData["PlayerName"].(string)

StrHeadUrl := ProtocolData["HeadUrl"].(string)

StrSex := ProtocolData["Sex"].(string)

StrConstellation := ProtocolData["Constellation"].(string)

StrPlayerSchool := ProtocolData["PlayerSchool"].(string)

StrToken := ProtocolData["Token"].(string)

_ = StrToken

// 获取在线人数

ddd := make(map[string]interface{})

csv.M_CSV.LollipopGo_RLockRange(ddd)

// 查询数据库,找出游戏服务器的uid信息

// 返回的数据操作

datadb := DB_Save_RoleST(StrUID, StrPlayerName, StrHeadUrl, StrPlayerSchool, StrSex, StrConstellation, 0, 0, 2000, 0, 0)

fmt.Println("--------------------------:", datadb)

// 个人数据

personalmap := make(map[string]*player.PlayerSt)

personalmap["1"] = &datadb

_ = personalmap["1"].OpenID

// 组装数据

data := &Proto2.GW2G_PlayerEntryHall{

Protocol: Proto.G_GameGlobal_Proto, // 游戏主要协议

Protocol2: Proto2.GW2G_PlayerEntryHallProto2,

OpenID: StrOpenID,

PlayerName: StrPlayerName,

HeadUrl: StrHeadUrl,

Constellation: StrConstellation,

Sex: StrSex,

GamePlayerNum: ddd,

RacePlayerNum: nil,

Personal: personalmap,

DefaultMsg: nil,

DefaultAward: nil,

}

fmt.Println(data)

PlayerSendToServer(conn, data)

// 保存玩家的数据 -- 主要是为了

return

}

// 保存数据都DB 人物信息

func DB_Save_RoleST(uid, strname, HeadURL, StrPlayerSchool, Sex, Constellation string, Lev, HallExp, CoinNum, MasonryNum, MCard int) player.PlayerSt {

args := player.PlayerSt{

UID: util.Str2int_LollipopGo(uid),

VIP_Lev: 0,

Name: strname,

HeadURL: HeadURL,

Sex: Sex,

PlayerSchool: StrPlayerSchool,

Lev: Lev,

HallExp: HallExp,

CoinNum: CoinNum,

MasonryNum: MasonryNum,

MCard: MCard,

Constellation: Constellation,

OpenID: util.MD5_LollipopGO(uid),

}

var reply player.PlayerSt

// 异步调用【结构的方法】

if ConnRPC != nil {

// ConnRPC.Call("Arith.SavePlayerST2DB", args, &reply) 同步调用

divCall := ConnRPC.Go("Arith.SavePlayerST2DB", args, &reply, nil)

replyCall :=

_ = replyCall.Reply

} else {

fmt.Println("ConnRPC == nil")

}

return reply

}

func initConn(conn *websocket.Conn) {

data := &Proto2.G2GW_ConnServer{

Protocol: Proto.G_GameGlobal_Proto,

Protocol2: Proto2.G2GW_ConnServerProto2,

ServerID: util.MD5_LollipopGO("8894" + "Global server"),

}

PlayerSendToServer(conn, data)

return

}

每天坚持学习1小时Go语言，大家加油，我是彬哥，下期见！如果文章中不同观点、意见请文章下留言或者关注下方订阅号反馈！

Golang语言社区

go 服务器 源码,LollipopGo开源游戏服务器框架--global服务器源码相关推荐

  1. golang 麻将服务器源码,LollipopGo开源游戏服务器框架--global服务器源码

    大家好,我是彬哥,本节给大家讲下LollipopGov1.0.20190102版本游戏服务器globla服务器,抛砖引玉了,主要是针对Go语言游戏服务器Global服务器处理. package mai ...

  2. java游戏服务器面试_【网易游戏java手游服务器面试】主要根据以往工作经历...-看准网...

    10.21终面已参加,希望能顺利通过终面拿到offer-❤一共三轮,电话面试+笔试+视频面试,视频面试3V110月19日投的新媒体运营的简历,HR说因为是周末,等工作日再联系我,在周一下午三点我接到了 ...

  3. java bbs源码_java开源论坛系统 jeebbs v7.0 源码包

    JEEBBS最新版本采用hibernate3+spring mvc+spring3+freemarker技术架构,重新设计了jeebbs,重新架构后的JEEBBS性能得到了很大的提升,功能相比jeeb ...

  4. 开源游戏服务器端框架Firefly正式将GFirefly整合

    Firefly 的重要迭代版本GFirefly已经独立推出并运维了近9个月时间,已有200余家国内各大手机游戏厂商开始陆续使用GFirefly进行其新手游产品的开发.(2014游戏行业国内最大黑马&q ...

  5. TBSchedule淘宝开源定时任务调度框架（附客户端源码demo）

    淘宝开源定时任务调度框架 下载TBSchedule源码svn地址:code.taobao.org/p/tbschedule/src/trunk/ 内容包括两部分:TBSchedule源码及开发依赖包t ...

  6. cocos creator2.3.5休闲游戏英文版（连连看）源码H5+安卓+IOS三端源码

    cocos creator2.3.5休闲游戏英文版(连连看)源码H5+安卓+IOS三端源码,开发脚本为typeScript方便扩展和阅读,支持cocos creator2.X版本,完整的源码可直接运营 ...

  7. cocos creator经典游戏英文版《俄罗斯方块》源码H5+安卓+IOS三端源码

    cocos creator2.2.2经典游戏英文版<俄罗斯方块>源码H5+安卓+IOS三端源码,开发脚本为typeScript方便扩展和阅读,支持cocos creator2.X版本,完整 ...

  8. 少年歌行游戏一直显示连接服务器,少年歌行出现第三方登陆失败怎么办 解决方案一览...

    少年歌行出现第三方登陆失败怎么办,少年歌行是一款非常好玩的游戏,许多玩家被其优秀的内容和有趣的玩法所吸引.但是近日有小伙伴反应少年歌行出现第三方登陆失败,小编这里整理了一些少年歌行出现第三方登陆失败的 ...

  9. 三国杀正在连接服务器请稍后,三国杀名将传游戏出现无法连接服务器怎么处理 处理方案一览...

    三国杀名将传游戏出现无法连接服务器怎么处理 处理方案一览.三国杀名将传是一款非常好玩的游戏,许多玩家被其优秀的内容和有趣的玩法所吸引.但是近日有小伙伴反应无法连接服务器问题,小编这里整理了一些无法连接 ...

最新文章

  1. mysql获取多层嵌套json_使用两个mySQL查询来创建嵌套的JSON数组
  2. （chap4 IP协议） CIDR协议
  3. react学习(10)----react数组定义 从0开始 直接加个0下标空
  4. c++常用知识点，易错点，面试常问点
  5. Git清除用户名和密码
  6. 打印连续数字 java_java多线程连续打印字母数字问题
  7. 模板 - 数论 - 整除分块
  8. python input函数详解_Python如何使用input函数获取输入，看完你就会了
  9. 操作系统答案 第四版
  10. 【日常点滴015】python中学完pandas后的代码练习 附源数据文件
  11. 画圆的函数----（基于MATLAB）
  12. scala（三）：流程控制-分支控制、嵌套循环、for、while、do…while循环、循环中断、多支循环
  13. 多进程爬取补天的厂商
  14. HotFix移动热修复详解
  15. Kafka Broker 基本架构二
  16. 计算机中的文件资源组织方式是什么意思,Windows中的库是什么，以及如何使用它们来组织文件 | MOS86...
  17. IPD解读—需求管理（OR）流程方法论
  18. 基于超算平台气象预警并行计算架构研究
  19. 【报告分享】2021年百万经纪人调查报告-58安居客房产研究院 （附下载）
  20. Python爬虫实战(1)-爬取“房天下”租房信息(超详细)

热门文章

  1. 叮咚！你有一份来自明源云的圣诞邀约
  2. 用 Span 对 C# 进程中三大内存区域进行统一访问 ，太厉害了！
  3. 15分钟从零开始搭建支持10w+用户的生产环境(三)
  4. 谁说docker-compose不能水平扩展容器、服务多实例？
  5. Magicodes.IE 2.2里程碑需求和建议征集
  6. 使用.NET Core创建Windows服务 - 使用.NET Core工作器方式
  7. 领域驱动设计学习之路—DDD的原则与实践
  8. netcore开发windows普通服务(非Web)并一键发布到服务器
  9. ASP.NET Core 自定义认证方式--请求头认证
  10. MonkeyFest2018 微软最有价值专家讲座