Module: CNNTActionHelper

Includes:
Socket::Constants
Defined in:
lib/action/module/cnnt_action.rb

Instance Method Summary collapse

Instance Method Details

#cnnt_close(socket) ⇒ Object

关闭连接 用于长连接操作

参数

socket 用于操作的socket句柄

Example

cnnt_close socket



51
52
53
 
# File 'lib/action/module/cnnt_action.rb', line 51

def cnnt_close socket
	socket.close
end

#cnnt_connect(ip, port) ⇒ Object

建立连接 用于长连接操作

参数

  • ip

  • port

返回

socekt 句柄

Example:

socket = cnnt_connect 127.0.0.1, 1900



22
23
24
25
26
27
 
# File 'lib/action/module/cnnt_action.rb', line 22

def cnnt_connect ip, port
	socket = Socket.new( AF_INET, SOCK_STREAM, 0 )
	sockaddr = Socket.pack_sockaddr_in( port, ip )
	socket.connect( sockaddr )
	return socket
end

#cnnt_create_practical_server(port, cont) ⇒ Object

创建一个server 接收到的数据被放到cont数组中

该函数仅支持一个线程的连接请求

参数

port 端口cont 接收数据用的数组

返回

服务器线程句柄

Example

cont=[] cnnt_create_practical_server 1999, cont cnnt_direct_send “127.0.0.1”, 1999, “dddd” p cont



127
128
129
130
131
132
133
134
135
136
137
138
139
140
 
# File 'lib/action/module/cnnt_action.rb', line 127

def cnnt_create_practical_server port, cont
	svr_t = Thread.new {
		socket = Socket.new( AF_INET, SOCK_STREAM, 0 )
         		sockaddr = Socket.pack_sockaddr_in( port, 'localhost' )
	  	socket.bind( sockaddr )
          	socket.listen( 5 )
          	client, client_sockaddr = socket.accept
		loop do
			cont << client.recvfrom(1024)[0]
		end
       	  	socket.close
	}
	return svr_t
end

#cnnt_create_server(port) ⇒ Object

}



93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
 
# File 'lib/action/module/cnnt_action.rb', line 93

def cnnt_create_server port
	svr_t = Thread.new {
		socket = Socket.new( AF_INET, SOCK_STREAM, 0 )
         		sockaddr = Socket.pack_sockaddr_in( port, 'localhost' )
	  	socket.bind( sockaddr )
          	socket.listen( 5 )
		loop do
          		client, client_sockaddr = socket.accept
			Thread.new{
				loop do
					yield client
				end
			}
		end
       	  	socket.close
	}
	return svr_t
end

#cnnt_direct_send(ip, port, cont) ⇒ Object

发送一次数据 用于短连接操作

参数

ip ip port 端口cont 要发送的内容

返回

发送的数据长度

Example

cnnt_short_send “127.0.0.1”, 1900, “dddd”



67
68
69
70
71
72
73
74
 
# File 'lib/action/module/cnnt_action.rb', line 67

def cnnt_direct_send ip, port, cont
	socket = Socket.new( AF_INET, SOCK_STREAM, 0 )
         	sockaddr = Socket.pack_sockaddr_in( port, ip )
         	socket.connect( sockaddr )
	ret = socket.send cont, 0
         	socket.close
	return ret
end

#cnnt_send(socket, cont) ⇒ Object

发送数据 用于长连接操作

参数

socket 用于发送的socket句柄cont 发送的内容

返回

发送的数据长度

Example

cnnt_send socket, “dddd”



40
41
42
 
# File 'lib/action/module/cnnt_action.rb', line 40

def cnnt_send socket, cont
	socket.send cont, 0
end

#cnnt_stop_server(svr) ⇒ Object

停止服务线程

参数

svr 服务器线程句柄

Example

cnnt_stop_server svr



149
150
151
 
# File 'lib/action/module/cnnt_action.rb', line 149

def cnnt_stop_server svr
	svr.exit
end