文档章节

Skynet 简单的服务编写 (2)

水果糖
 水果糖
发布于 2017/02/25 03:37
字数 554
阅读 195
收藏 1

            前面我们简单的用Skynet 写了个lua服务,实现了简单的发送消息并调用输出“Hello World!”

    而由于Skynet 是网络框架,所以我们这次用Skynet写一个简单的服务来监听80端口。

 

   具体流程如下:

        1、 在main文件入口内监ip为:192.168.2.5,端口为:80

        2、 使用每个连接进来后新建并初始化一个服务用来处理连接相关操作。

 

#main.lua

local skynet = require "skynet"
local socket = require "socket"



skynet.start(function()

	local id = socket.listen("192.168.2.5",80)
	
	socket.start(id , function(fd,addr)
	
		local cnn = skynet.newservice "network"
		skynet.send(cnn,"lua","SOCKET",fd)
		socket.abandon(fd)

	end)
	--skynet.exit()
end)

注意:这里为什么不在最后调用skynet.exit()呢?

     因为start函数是非阻塞的,所以套接字的回调函数注册到skynet框架后会立刻返回;如果后面调用skynet.exit后将立刻退出main服务,从而清除当前匿名回调函数内的所有内容。

 

#network.lua

local skynet = require "skynet"
local socket = require "socket"

skynet.init(function()
	print("init was success...")
end)

local CMD = { }


function CMD.SOCKET(fd)

	socket.start(fd)
	socket.write(fd,"welcome!\n\r>>")

	while fd do

		local buf = socket.readline(fd)

		if buf and buf ~= "exit()" then

			socket.write(fd,"you say: " .. buf .. "\r\n>>")

		else
			skynet.error("Client Closed this Connection...")
			socket.close(fd)
			break
		end
	end

end

skynet.start(function()
	skynet.dispatch("lua",function(_,_,cmd,fd)

		local f = assert(CMD[cmd])
		if f then
			f(fd)
		end
	end)
end)

 

        在接收到client端的连接后,main服务将立即新建一个network服务;然后主动调用network通过lua消息将套接字fd传递到network服务内。然后我们可以看到network服务通过接收cmd命令(也就是“SOCKET”),然后进行CMD.SOCKET函数调用传参。

        然后就是我们熟悉的socket的read与write了!通过一个循环我们实现了简单的echo 服务器,并且在Client端离线后我们还需要手动关闭套接字。切记在关闭套接字后还需要跳出while 循环,否则Skynet还会检测到你的服务处于deadloop.....

        最后,如果对API或者各种库的用法有什么不理解的可以到Skynet的Wiki上自行查询;Wik 是中文版且写的十分详细,有兴趣的朋友可以自行研究下。

        

© 著作权归作者所有

共有 人打赏支持
水果糖
粉丝 17
博文 158
码字总数 52482
作品 0
深圳
程序员
私信 提问
游戏服务器架构调研报告

服务器架构调研报告 刘源霖20151119 1. 前言 本文档主要是调研分析新的手游服务端架构,为下一款手游服务端研发提供可参考的方案。主要的参考点是数据持久化,并发效率,分布式,沙盒机制,热...

shezjl
2016/01/22
2K
1
skynet 入门笔记(2):service 消息收发

Skynet 入门笔记(2):Service 消息收发 编写第一个 service 成功了,接下来考虑多个 service 之间如何通信的问题。 skynet 是单进程多线程框架,每个 lua service 独立运行在自己的 lua vm...

uniqptr
06/27
0
0
开源并发框架 Skynet 发布第一个正式版 v0.1.0

距离 skynet 开源项目的公布 已经有 20 月+ 了,如果从闭源阶段算起,已经超过了 30 个月。在我们公司内部有五个项目使用 skynet 开发,据有限的了解,在我们公司之外,至少有两个正式项目使...

C_Z
2014/04/23
3.9K
6
Skynet 设计综述

多线程模式,可以使得状态共享、数据交换更加高效。而多线程模型的诸多弊端,比如复杂的线程锁、线程调度问题等,都可以通过减小底层的规模,精简设计,最终把危害限制在很小的范围内。 做为...

曾劲松
2016/07/28
48
0
Skynet 1.0.0 RC 版发布,开源并发框架

拖了很久,终于决定给 skynet 1.0.0 封版了。比预期的时间 足足晚了半年,好在还是在 2015 年把这个事情启动了。 其实已经很久没有对已有特性做修改了,如果的项目是在今年 3 月份以后跟进的...

oschina
2015/12/29
2.4K
7

没有更多内容

加载失败,请刷新页面

加载更多

《稻盛和夫经营学》读后感心得体会3180字范文

《稻盛和夫经营学》读后感心得体会3180字范文: 一代日本经营之圣稻盛和夫凭借刻苦勤奋的精神以及深植于佛教的商业道德准则,成为了“佛系”企业家的代表人物。在《稻盛和夫经营学》“领导人...

原创小博客
9分钟前
0
0
java框架学习日志-5(常见的依赖注入)

依赖注入(dependency injection) 之前提到控制反转(Inversion of Control)也叫依赖注入,它们其实是一个东西,只是看的角度不同,这章详细说一下依赖注入。 依赖——指bean对象创建依赖于...

白话
25分钟前
1
0
红外接收器驱动开发

背景:使用系统的红外遥控软件没有反应,然后以为自己接线错误,反复测试,结果烧坏了一个红外接收器,信号主板没有问题。所以自己开发了一个红外接收器的python驱动。接线参见https://my.os...

mbzhong
今天
2
0
ActiveMQ消息传送机制以及ACK机制详解

AcitveMQ是作为一种消息存储和分发组件,涉及到client与broker端数据交互的方方面面,它不仅要担保消息的存储安全性,还要提供额外的手段来确保消息的分发是可靠的。 一. ActiveMQ消息传送机...

watermelon11
今天
1
0
HashTable和Vector为什么逐渐被废弃

HashTable,不允许键值为null,还一个就是put方法使用sychronized方法进行线程同步,单线程无需同步,多线程可用concurren包的类型。 如编程思想里面说的作为工具类,封闭性做的不好没有一个...

noob_chr
昨天
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部