套接字是網(wǎng)絡(luò)通信通道的端點(diǎn)，客戶(hù)端和服務(wù)器之間相互通信。它們可以在同一臺(tái)機(jī)器上或在不同的機(jī)器上進(jìn)行通信。

套接字(Socket)的類(lèi)型有以下幾種：

• TCP套接字
• UDP套接字
• UNIX套接字

有兩個(gè)級(jí)別的套接字 - 高級(jí)和低級(jí)。 低級(jí)訪(fǎng)問(wèn)允許您處理系統(tǒng)支持的套接字。 它允許實(shí)現(xiàn)無(wú)連接和面向連接的協(xié)議。 高級(jí)訪(fǎng)問(wèn)允許您處理像HTTP和FTP這樣的網(wǎng)絡(luò)協(xié)議。

示例-1

創(chuàng)建一個(gè)服務(wù)器端 - server1.rb，代碼如下 -

#!/usr/bin/ruby   
# file : server1.rb

require 'socket'   

server = TCPServer.open(8088)   
loop {   
    client = server.accept   
    client.puts "Hello. This is socket programming"   
    client.close   
}

在上述代碼中，需要包括預(yù)先安裝的socket模塊。 在系統(tǒng)上使用8088端口。當(dāng)然您可根據(jù)需要可以使用任何其它的端口。

啟動(dòng)循環(huán)，接受所有連接到8088端口，并通過(guò)套接字網(wǎng)絡(luò)將數(shù)據(jù)發(fā)送給客戶(hù)端。

最后，關(guān)閉套接字。

創(chuàng)建一個(gè)客戶(hù)端代碼 - client1.rb

#!/usr/bin/ruby   
# file : client1.rb
require 'socket'   

hostname = 'localhost'   
port = 8088   

s = TCPSocket.open(hostname, port)   

while line = s.gets   
    puts line.chomp   
end   
s.close

在上述代碼中，需要包括預(yù)先安裝的socket模塊。 創(chuàng)建一個(gè)套接字并將其連接到端口8088。

創(chuàng)建一個(gè)while循環(huán)來(lái)獲取通過(guò)套接字發(fā)送的所有信息。

最后，關(guān)閉套接字。

執(zhí)行輸出：

打開(kāi)終端，轉(zhuǎn)到保存上述兩個(gè)文件的目錄，在本示例中，所有代碼均保存在：F:\worksp\ruby 目錄下。

現(xiàn)在打開(kāi)兩個(gè)終端。在第一個(gè)終端先執(zhí)行服務(wù)器腳本(ruby server1.rb)，服務(wù)器腳本啟動(dòng)完成后，在第二個(gè)終端執(zhí)行以下命令執(zhí)行客戶(hù)端腳本，得到以下結(jié)果 -

F:\worksp\ruby>ruby client1.rb
Hello. This is socket programming

F:\worksp\ruby>

多個(gè)客戶(hù)端套接字編程

對(duì)于多個(gè)客戶(hù)端進(jìn)行套接字編程，將需要一個(gè)循環(huán)和一些線(xiàn)程來(lái)接受和響應(yīng)多個(gè)客戶(hù)端連接和交互。

示例-2

創(chuàng)建一個(gè)服務(wù)器端 - server2.rb，代碼如下 -

#!/usr/bin/env ruby -w
# file : server2.rb

require "socket"   
class Server   
  def initialize( port, ip )   
    @server = TCPServer.open( ip, port )   
    @connections = Hash.new   
    @rooms = Hash.new   
    @clients = Hash.new   
    @connections[:server] = @server   
    @connections[:rooms] = @rooms   
    @connections[:clients] = @clients   
    run   
  end   

  def run   
    loop {   
      Thread.start(@server.accept) do | client |   
        nick_name = client.gets.chomp.to_sym   
        @connections[:clients].each do |other_name, other_client|   
          if nick_name == other_name || client == other_client   
            client.puts "This username already exist"   
            Thread.kill self   
          end   
        end   
        puts "#{nick_name} #{client}"   
        @connections[:clients][nick_name] = client   
        client.puts "Connection established..."   
        listen_user_messages( nick_name, client )   
      end   
    }.join   
  end   

  def listen_user_messages( username, client )   
    loop {   
      msg = client.gets.chomp   
      @connections[:clients].each do |other_name, other_client|   
        unless other_name == username   
          other_client.puts "#{username.to_s}: #{msg}"   
        end   
      end   
    }   
  end   
end   

Server.new( 8088, "localhost" )

在上面的代碼中，服務(wù)器將與客戶(hù)端在指定的端口(8088)來(lái)建立連接。 在這里，每個(gè)連接的用戶(hù)需要一個(gè)線(xiàn)程來(lái)處理用戶(hù)連接信息交互。

run方法驗(yàn)證輸入的名稱(chēng)是否唯一。 如果用戶(hù)名已經(jīng)存在，連接將被斷開(kāi)，否則將建立連接。

listen_user_messages方法用于偵聽(tīng)用戶(hù)消息并將其發(fā)送給所有用戶(hù)。

創(chuàng)建一個(gè)客戶(hù)端代碼 - client2.rb

#!/usr/bin/env ruby -w
# file : client2.rb

require "socket"   
class Client   
  def initialize( server )   
    @server = server   
    @request = nil   
    @response = nil   
    listen   
    send   
    @request.join   
    @response.join   
  end   

  def listen   
    @response = Thread.new do   
      loop {   
        msg = @server.gets.chomp   
        puts "#{msg}"   
      }   
    end   
  end   

  def send   
    puts "Enter your name:"   
    @request = Thread.new do   
      loop {   
        msg = $stdin.gets.chomp   
        @server.puts( msg )   
      }   
    end   
  end   
end   

server = TCPSocket.open( "localhost", 8088 )   
Client.new( server )

在上面的代碼中，創(chuàng)建了Client類(lèi)用來(lái)處理用戶(hù)。

在 send 和 listen 方法中創(chuàng)建兩個(gè)線(xiàn)程，以便可以同時(shí)讀取/寫(xiě)入消息。

執(zhí)行輸出：

下面顯示兩個(gè)客戶(hù)端之間的聊天消息，首先執(zhí)行(ruby server2.rb)，然后再運(yùn)行兩個(gè)客戶(hù)端，在兩個(gè)客戶(hù)端之間發(fā)送信息聊天。

服務(wù)器(server2.rb)記錄每個(gè)客戶(hù)端連接信息 -

F:\worksp\ruby>ruby server2.rb
maxsu #<TCPSocket:0x00000002c3dc30>
minsu #<TCPSocket:0x00000002c3d730>
......