44 lines
1.3 KiB
Lua
44 lines
1.3 KiB
Lua
local skynet = require "skynet"
|
||
local socket = require "skynet.socket"
|
||
local httpd = require "http.httpd"
|
||
local urllib = require "http.url"
|
||
local sockethelper = require "http.sockethelper"
|
||
|
||
-- 发送html
|
||
local function response(id, ...)
|
||
local ok, err = httpd.write_response(sockethelper.writefunc(id), ...)
|
||
if not ok then
|
||
-- if err == sockethelper.socket_error , that means socket closed.
|
||
skynet.error(string.format("fd = %d, %s", id, err))
|
||
end
|
||
end
|
||
|
||
local function handle(id)
|
||
socket.start(id) -- 这里一定要start，否则不会接收来自客户端的请求
|
||
print("handle",id)
|
||
local code, url, method, header, body = httpd.read_request(sockethelper.readfunc(id), 8192)
|
||
print(code, url, method, header, body)
|
||
if code then
|
||
print(code, url, method, header, body)
|
||
local f = io.open("/home/gdut17/skynet_test/websocket/index3.html", "r")
|
||
local index_html = f:read("*a")
|
||
f:close()
|
||
response(id, code, index_html)
|
||
end
|
||
socket.close(id)
|
||
end
|
||
|
||
local function accept(clientfd, addr)
|
||
--skynet.newservice("agent", clientfd, addr)
|
||
-- skynet.error("http req ",clientfd,addr)
|
||
--handle(clientfd)
|
||
skynet.fork(handle,clientfd)
|
||
end
|
||
|
||
|
||
skynet.start(function ()
|
||
local listenfd = socket.listen("0.0.0.0", 9999)
|
||
skynet.error("http server listen on 0.0.0.0:9999")
|
||
socket.start(listenfd, accept)
|
||
end)
|