| 赞 | 8 |
| VIP | |
| 好人卡 | |
| 积分 | 19 |
| 经验 | |
| 最后登录 | 2026-5-25 |
| 在线时间 | 529 小时 |
宛若
- 梦石
- 0
- 星屑
- 1888
- 在线时间
- 529 小时
- 注册时间
- 2007-8-19
- 回帖
- 1466
 
|
加入我们，或者，欢迎回来。
您需要 登录 才可以下载或查看，没有账号？注册会员
×
本帖最后由 逸豫 于 2014-2-15 00:16 编辑
啊，没错我知道的今天是情人节与元宵节，在这种与我无关的日子里还在干这种活真是对不起了
纯Ruby实现的Socket网络通信
稍微封装了一下，采用了非阻塞的方式，注意每帧调用update
使用方法
[pre lang="ruby" line="1"]#使用前请先调用
NET.init
#创建Socket类
socket = NET::Socket.new
#连接
socket.connect("127.0.0.1",20001)
#每帧刷新
loop do
Graphics.update
Input.update
socket.update
#接收到消息
if socket.recv
socket.send(socket.recv)
end
end
#另附
#在port端口上进行监听
socket.listen(port)
#获取监听得到的客户端socket
socket.accepted_sockets.each do |cs|
#可以直接操纵
cs.send("welcome")
end
#是否已经连接，因为使用了非阻塞的方法，从调用connect方法到实际连接上有延迟
socket.connected?
#是否有错误
socket.error?
#错误码可以通过以下代码获取，该错误码与WSAGetLastError获取的错误码一致
socket.errcode
#是否有内容需要发送
socket.sending?
#是否在监听状态
socket.listening?
#停止监听（仅仅是不调用accept方法而已）
socket.stop_listening
#继续监听
socket.continue_listening[/pre]
以上脚本仅供参考，并未经测试
一些吐槽
用Ruby操作Win32API就好像在一堆void指针上跳舞
一开始看错了结构体定义导致了一个需要400字节长度的结构体指针的参数被我直接传送了一个14字节长的字符串……而且在win7下竟然表现良好，在WINXP下也总是在奇怪的地方报内存错误，在没调试器的情况下DEBUG真是恶心（其实有也是一样恶心就是了……
没使用select，因为select还要自己设计那啥结构，我懒……
在一条消息还没发出去之前就继续send会导致两条消息被合成一条发过去，具体可以在测试DEMO的时候频繁按下某键看结果
因为RM的限制Graphics.update会在游戏处于后台的时候卡住游戏，所以当游戏处于后台时socket操作全部被暂停，积下没有收到的信息会在一次recv过程中合并成一条消息接收（后台运行可破之
具体代码可以参考DEMO
顺便一提核心脚本在DEMO脚本页的第一项……忘了写名字
顺便用vLan和别人联机的时候死活收不到消息，明明用家里的两台机子一台做主另一台挂上德国的VPN通过vLan去连都能连上的……
DEMO的使用方法是在连接以后按下游戏中能够按下的按键（ZXC上下左右之类），然后另一端会收到按键被按下的消息
一些截图
DEMO下载
https://dl.dropboxusercontent.com/u/322483/socket.7z
核心脚本
[pre lang="ruby" line="1"]#encoding: utf-8
module NET
#USER_DEFINED_CONST
MAX_BUFFER = 4096
#const
WSADESCRIPTION_LEN = 256
WSASYS_STATUS_LEN = 128
AF_INET = 2
SOCK_STREAM = 1
IPPROTO_TCP = 6
INVALID_SOCKET = ~0
SOCKET_ERROR = -1
INADDR_ANY = 0x00000000
SOMAXCONN = 0x7fffffff
FIONBIO = 2147772030
EINPROGRESS = 10036
EISCONN = 10056
EWOULDBLOCK = 10035
EINVAL = 10022
#win32api
API_WSAStartup = Win32API.new('ws2_32','WSAStartup','ip','i')
API_WSACleanup = Win32API.new('ws2_32','WSACleanup','v','i')
API_socket = Win32API.new('ws2_32','socket','iii','i')
API_htons = Win32API.new('ws2_32','htons','i','i')
API_ntohs = Win32API.new('ws2_32','ntohs','i','i')
API_htonl = Win32API.new('ws2_32','htonl','L','L')
API_inet_addr = Win32API.new('ws2_32','inet_addr','p','L')
API_inet_ntoa = Win32API.new('ws2_32','inet_ntoa','L','p')
API_ioctlsocket = Win32API.new('ws2_32','ioctlsocket','iip','i')
API_bind = Win32API.new('ws2_32','bind','ipi','i')
API_listen = Win32API.new('ws2_32','listen','ii','i')
API_accept = Win32API.new('ws2_32','accept','ipp','i')
API_connect = Win32API.new('ws2_32','connect','ipi','i')
API_recv = Win32API.new('ws2_32','recv','ipii','i')
API_send = Win32API.new('ws2_32','send','ipii','i')
API_closesocket = Win32API.new('ws2_32','closesocket','i','i')
API_WSAGetLastError = Win32API.new('ws2_32','WSAGetLastError','v','i')
def self.init
#最后两个char是为了内存对齐（byte alignment）理论上说并非必须
wsdata_types = "SSc#{WSADESCRIPTION_LEN+1}c#{WSASYS_STATUS_LEN+1}SSLcc"
wsadata = ([0]*(WSADESCRIPTION_LEN+WSASYS_STATUS_LEN+9)).pack(wsdata_types)
version = [2,2].pack("CC").unpack("S")[0]
if API_WSAStartup.call(version,wsadata) != 0
false
else
@inited = true
end
end
def self.inited?
return @inited
end
class Socket
attr :state
attr :errcode
attr :accepted_sockets
def initialize
@state = :not_ready
@errcode = 0
@accepted_sockets = []
return false unless NET.inited?
@socket = API_socket.call(AF_INET,SOCK_STREAM,IPPROTO_TCP)
if @socket == INVALID_SOCKET
return false
end
flag = [1].pack('L')
if API_ioctlsocket.call(@socket,FIONBIO,flag) == SOCKET_ERROR
return false
end
@state = :ready
end
def connected?
return @state == :connected
end
def error?
return @state == :error
end
def sending?
return @state == :sending
end
def listening?
return @state == :listening
end
def update
@recv = nil
@accepted_sockets.each{ |cs| cs.update }
case @state
when :connecting
if @connect_info.nil?
@state = :ready
else
if API_connect.call(@socket,@connect_info,@connect_info.size) == SOCKET_ERROR
ref = API_WSAGetLastError.call
if ref == EISCONN
@state = :connected
elsif ref != EWOULDBLOCK && ref != EINPROGRESS && ref != EINVAL
puts "Error occured when connecting"
@state = :error
@errcode = ref
end
p ref
else
@state = :connected
end
end
when :connected
@buf = "\0"*MAX_BUFFER if @buf.nil?
if (response_size = API_recv.call(@socket,@buf,@buf.size,0)) == SOCKET_ERROR
ref = API_WSAGetLastError.call
if(ref != EWOULDBLOCK)
@state = :error
@errcode = ref
end
else
@recv = @buf[0...response_size]
end
when :sending
if API_send.call(@socket,@message,@message.size,0) == SOCKET_ERROR
ref = API_WSAGetLastError.call
if ref != EWOULDBLOCK
@state = :error
@errcode = ref
puts "Error occured when sending"
end
else
@state = :connected
end
when :listening
@ci = '\0'*16 if @ci.nil?
len = [@ci.size].pack('i')
if (cs = API_accept.call(@socket,@ci,len)) == SOCKET_ERROR
ref = API_WSAGetLastError.call
if ref != EWOULDBLOCK
@state = :error
@errcode = ref
end
else
@accepted_sockets.push NET::ClientSocket.new({:socket => cs,
:client_info => @ci})
end
end
end
def connect(ip,port)
p ip,port.to_i
return false if @state != :ready
sockaddr_in = [AF_INET,API_htons.call(port.to_i),API_inet_addr.call(ip)]
sockaddr_in += ([0]*8)
@connect_info = sockaddr_in.pack('sSLc*8')
@state = :connecting
end
def send(message)
return false if @state != :connected && @state != :sending
@message = message
if API_send.call(@socket,@message,@message.size,0) == SOCKET_ERROR
ref = API_WSAGetLastError.call
if ref != EWOULDBLOCK
puts "Error occured when send"
@state = :error
@errcode = ref
else
@state = :sending
end
else
@state = :connected
end
end
def recv
return false if @state != :connected
return @recv
end
def listen(port)
return if @state != :ready
#server info
sockaddr_in_server = [AF_INET,API_htons.call(port),API_htonl.call(INADDR_ANY)]
sockaddr_in_server += ([0]*8);
server_info = sockaddr_in_server.pack('sSLc*8')
#bind
if API_bind.call(@socket,server_info,server_info.size) == SOCKET_ERROR
return false
end
#listen
if API_listen.call(@socket,SOMAXCONN) == SOCKET_ERROR
return false
end
@state = :listening
end
def stop_listening
@state = :listening_stoped
end
def continue_listening
@state = :listening
end
end
class ClientSocket < Socket
attr :ip
attr :port
def initialize(params)
@state = :not_ready
@accepted_sockets = []
return false unless NET.inited?
@state = :connected
@socket = params[:socket]
@connect_info = params[:client_info]
info = @connect_info.unpack('sSLc*8')
@ip = API_inet_ntoa.call(info[2])
@port = API_ntohs.call(info[1])
end
end
end[/pre] |
评分
-
查看全部评分
|
写轮眼
发表于 2014-2-15 00:06:27
提升卡
沉默号角
喧嚣号角
变色卡
升龙剑
