spatial/NetSubSystem_C.lua at main · etan007/spatial · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
local driver = require "clientcommon.net_driver"
local print_r = require "clientcommon.print_r"
local tool = require "clientcommon.tool"
require "clientcommon.class"
----------------------------------------------------------------


local NetSubSystem_C = class("NetSubSystem_C")

function NetSubSystem_C:ctor()
    self.bConnect = false
end

---服务器的广播消息
--[[function OnRecvNotify(name,args,timestamp)
    --print("NetSubSystem_C-OnRecvNotify   "..name.."  data:  "..tool.dump_table(args))
    local funcName = "On"..name
    if NetSubSystem_C[funcName] then
        NetSubSystem_C[funcName](NetSubSystem_C,name,args)
    end
end--]]

function NetSubSystem_C:Connect(ip, port)
    local netClient = require "luaClient"
    local socket = netClient.TcpClient:new()
    socket:Init(0)

    self.socket = socket
    self.driver = driver.new()
    self.driver:Init_driver()
    self.driver.tempid = self.player.tempid
    self.driver.socket = socket

    --self.driver.recv_notify = OnRecvNotify
    self.driver.recv_notify = function(name, args, timestamp)
        --print("NetSubSystem_C-OnRecvNotify   "..name.."  data:  "..tool.dump_table(args))
        local funcName = "On" .. name
        if self[funcName] then
            self[funcName](self, name, args)
        end
    end

    self.bStart = true
    self.lastPingTime = os.time()
    socket.OnDisconnectCB = function(code, msg)
        print("on OnDisconnectCB")
        self.bConnect = false
        -- driver:OnDisconnectCB(code,msg)
    end
    socket.OnConnectCB = function(code, msg)
        print("OnConnectCB")
        print(code, msg)
        if code ~= 0 then
            self.bConnect = false
            return
        end

        self.bConnect = true

    end
    socket.OnRecvCB = function(msg)
        --print("OnRecvCB")
        infoLog("socket.OnRecvCB msg length ...")
        --infoLog(string.len(msg))
        self.driver.last = self.driver.last .. msg
    end


    socket:Connect(ip, port)
end

function NetSubSystem_C:RPC(name, args, cb, timeout, bsync)
    if self.bStart then
        self.driver:send_reques_async(name, args, cb, timeout)
    end
end

function NetSubSystem_C:Request(name, args, reason)
    if self.bStart then
        return self.driver:send_request(name, args, reason)
    end

    return nil
end

function NetSubSystem_C:OnTick(DeltaTime)
    --print("NetSubSystem_C:ReceiveOnUpdate")
    if self.bStart then
        self.driver:dispatch_package()
        self.driver:process_timeout()

        local nowtime = self.driver:get_time()
        if nowtime - self.lastPingTime > 30 then
            self.lastPingTime = nowtime
            self:Ping(nowtime)
        end

    end
end

function NetSubSystem_C:SetServerTime(timestamp)
    self.driver:set_time(timestamp)
end

--Ping包
function NetSubSystem_C:Ping(nowtime)
    local PingCB = function(args)
        if args.timeout then
            print("ping timeout")
            return
        end

        --print("ping ret")
    end

    if self.bStart then
        self:RPC("Ping", { timestamp = nowtime }, PingCB, 10, true)
    end
end

-----------------------------房间相关----------------------
--进入房间通知
function NetSubSystem_C:OnJoinRoomNotify(name, args)
end

-----------------------------物品相关----------------------
---道具变化通知
function NetSubSystem_C:OnItemChangeNotify(name, args)

end

-----------------------------邮件相关----------------------
-----------------------------邮件相关----------------------
-----------------------------订单相关----------------------
--拉起购买页面
function NetSubSystem_C:OnApplyOrderNotify(name, args)

end

--检查支付订单通知
function NetSubSystem_C:OnOrderCompSendItemNotify(name, args)

end

--订单道具发送通知
function NetSubSystem_C:OnOrderCompSendItemNotify(name, args)

end

return NetSubSystem_C