LuatOS/olddemo/socket/Air105/server_demo.lua

local libnet = require "libnet"

--下面演示用阻塞方式做自动应答服务器，只适合W5500
local dName = "D2_TASK"
local function netCB(msg)
	log.info("未处理消息", msg[1], msg[2], msg[3], msg[4])
end

local function serTask(port)
	local tx_buff = zbuff.create(1024)
	local rx_buff = zbuff.create(1024)
	local netc 
	local result, param, succ, rIP, rPort
	netc = socket.create(socket.ETH0, dName)
	--socket.debug(netc, true)
	socket.config(netc, port)
	while true do

		log.info(rtos.meminfo("sys"))
		result = libnet.waitLink(dName, 0, netc)
		result = libnet.listen(dName, 0, netc)
		if result then
            result,_ = socket.accept(netc, nil)    --W5500的硬件协议栈不支持一对多
            if result then
			    log.info("客户端连上了")
			    libnet.tx(dName, 0, netc, "helloworld")
            end
		end
		while result do
			succ, param, rIP, rPort = socket.rx(netc, rx_buff)
			if not succ then
				log.info("客户端断开了", succ, param, rIP, port)
				break
			end
			if rx_buff:used() > 0 then
				log.info("收到客户端数据，长度", rx_buff:used())
				tx_buff:copy(nil,rx_buff)   --把接收的数据返回给客户端
				rx_buff:del()
			end 

			if tx_buff:used() > 0 then
				result, param = libnet.tx(dName, 5000, netc, tx_buff)
			end
			if not result then
				log.info("发送失败了", result, param)
				break
			end
			tx_buff:del()
			if tx_buff:len() > 1024 then
				tx_buff:resize(1024)
			end
			if rx_buff:len() > 1024 then
				rx_buff:resize(1024)
			end
			log.info(rtos.meminfo("sys"))
			result, param = libnet.wait(dName, 5000, netc)
			if not result then
				log.info("客户端断开了", result, param)
				break
			end
		end
		libnet.close(dName, 5000, netc)
		log.info(rtos.meminfo("sys"))
		sys.wait(1000)
	end
end

local function UDPTask(port)
	local tx_buff = zbuff.create(1024)
	local rx_buff = zbuff.create(1024)
	local remote_ip = zbuff.create(18)
	local netc 
	local result, param, succ, rIP, rPort
	netc = socket.create(socket.ETH0, dName)
	socket.debug(netc, true)
	socket.config(netc, port, true)
	
	while true do

		log.info(rtos.meminfo("sys"))
		result = libnet.waitLink(dName, 0, netc)
		if result then
            result,_ = libnet.connect(dName, 5000, netc,"255.255.255.255",0)    --W5500的硬件协议栈不支持一对多
		end
		while result do
			result, param = libnet.wait(dName, 5000, netc)
			if not result then
				log.info("客户端断开了", result, param)
				break
			end
			succ, param, rIP, rPort = socket.rx(netc, rx_buff)
			if not succ then
				log.info("客户端断开了", succ, param)
				break
			end
			if rx_buff:used() > 0 then
				remote_ip:copy(0, rIP)	--用于后续处理，必须的
				if remote_ip[0] == 0 then
					rIP = remote_ip[1] .. "." .. remote_ip[2] .. "." .. remote_ip[3] .. "." .. remote_ip[4] --不是必须的，只是打印一下方便看看
					log.info("收到客户端数据，长度", rx_buff:used(), rIP, rPort)
				else
					log.info("收到客户端数据，长度", rx_buff:used()) --w5500暂时支持IPV4，就不处理IPV6的情况了
				end
				tx_buff:copy(nil,rx_buff)   --把接收的数据返回给客户端
				rx_buff:del()
			end 

			if tx_buff:used() > 0 then
				if remote_ip[0] == 0 then
					result, param = libnet.tx(dName, 5000, netc, tx_buff, remote_ip:query(1,4,false), rPort)
				else
					result = true	--w5500暂时支持IPV4，就不处理IPV6的情况了
				end
			end
			if not result then
				log.info("发送失败了", result, param)
				break
			end
			tx_buff:del()
			if tx_buff:len() > 1024 then
				tx_buff:resize(1024)
			end
			if rx_buff:len() > 1024 then
				rx_buff:resize(1024)
			end
			log.info(rtos.meminfo("sys"))

		end
		libnet.close(dName, 5000, netc)
		log.info(rtos.meminfo("sys"))
		sys.wait(1000)
	end
end

function SerDemo(port)
	sysplus.taskInitEx(serTask, dName, netCB, port)
end

function UDPSerDemo(port)
	sysplus.taskInitEx(UDPTask, dName, netCB, port)
end