summaryrefslogtreecommitdiff
path: root/xmake/modules/private/service/server.lua
blob: e2ccbbd8673a6b85694b52ee0c2f09b69c4da9a2 (plain)
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
--!A cross-platform build utility based on Lua
--
-- Licensed under the Apache License, Version 2.0 (the "License");
-- you may not use this file except in compliance with the License.
-- You may obtain a copy of the License at
--
--     http://www.apache.org/licenses/LICENSE-2.0
--
-- Unless required by applicable law or agreed to in writing, software
-- distributed under the License is distributed on an "AS IS" BASIS,
-- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-- See the License for the specific language governing permissions and
-- limitations under the License.
--
-- Copyright (C) 2015-present, TBOOX Open Source Group.
--
-- @author      ruki
-- @file        server.lua
--

-- imports
import("core.base.object")
import("core.base.socket")

-- define module
local server = server or object()

-- init server
function server:init()
end

-- set handler
function server:handler_set(handler)
    self._HANDLER = handler
end

-- get the listen address
function server:addr()
    return "127.0.0.1"
end

-- get the listen port
function server:port()
    return 90091
end

-- run main loop
function server:runloop()
    assert(self._HANDLER, "no handler found!")
    local sock = socket.bind(self:addr(), self:port())
    sock:listen(100)
    print("%s: listening %s:%d ..", self, self:addr(), self:port())
    while true do
        local sock_client = sock:accept()
        if sock_client then
            scheduler.co_start(function (sock)
                self._HANDLER(self, sock)
                sock:close()
            end, sock_client)
        end
    end
    sock:close()
end

-- get class
function server:class()
    return server
end

function server:__tostring()
    return "<server>"
end

function main()
    local instance = server()
    instance:init()
    return instance
end