class Socket

• Socket
• IO::FileDescriptor
• Reference
• Object

Direct Known Subclasses

• IPSocket
• UNIXSocket

Defined in:

Constructors

• .new(fd : Int32, family, type, protocol = Protocol::IP)
• .new(family, type, protocol = Protocol::IP, blocking = false)

Class Method Summary

• .ip?(string : String)

  Returns true if the string represents a valid IPv4 or IPv6 address.

• .tcp(family : Family, blocking = false)

  Creates a TCP socket.

• .udp(family : Family, blocking = false)

  Creates an UDP socket.

• .unix(type : Type = Type::STREAM, blocking = false)

  Creates an UNIX socket.

Instance Method Summary

• #accept

  Accepts an incoming connection.

• #accept?

  Accepts an incoming connection.

• #bind(host : String, port : Int)

  Binds the socket to a local address.

• #bind(port : Int)

  Binds the socket on port to all local interfaces.

• #bind(addr)

  Binds the socket to a local address.

• #bind(addr, &block)

  Tries to bind the socket to a local address.

• #broadcast=(val : Bool)
• #broadcast?
• #close_read

  Calls shutdown(2) with SHUT_RD

• #close_write

  Calls shutdown(2) with SHUT_WR

• #connect(host : String, port : Int, connect_timeout = nil)

  Connects the socket to a remote host:port.

• #connect(addr, timeout = nil) : Nil

  Connects the socket to a remote address.

• #connect(addr, timeout = nil, &block)

  Tries to connect to a remote address.

• #family : Family
• #getsockopt(optname, optval, level = LibC::SOL_SOCKET)

  Returns the modified optval.

• #inspect(io)
• #keepalive=(val : Bool)
• #keepalive?
• #linger
• #linger=(val : Int?)

  WARNING: The behavior of SO_LINGER is platform specific.

• #listen(backlog = SOMAXCONN)

  Tells the previously bound socket to listen for incoming connections.

• #listen(backlog = SOMAXCONN, &block)

  Tries to listen for connections on the previously bound socket.

• #protocol : Protocol
• #receive(max_message_size = 512) : Tuple(String, Address)

  Receives a text message from the previously bound address.

• #receive(message : Bytes) : Tuple(Int32, Address)

  Receives a binary message from the previously bound address.

• #recv_buffer_size
• #recv_buffer_size=(val : Int32)
• #reuse_address=(val : Bool)
• #reuse_address?
• #reuse_port=(val : Bool)
• #reuse_port?
• #send(message, to addr : Address)

  Sends a message to the specified remote address.

• #send(message)

  Sends a message to a previously connected remote address.

• #send_buffer_size
• #send_buffer_size=(val : Int32)
• #setsockopt(optname, optval, level = LibC::SOL_SOCKET)

  NOTE optval is restricted to Int32 until sizeof works on variables.

• #type : Type

Constructor Detail

Class Method Detail

Instance Method Detail

require "socket"

server = TCPServer.new(2202)
socket = server.accept
socket.puts Time.now
socket.close

require "socket"

server = TCPServer.new(2202)
if socket = server.accept?
  socket.puts Time.now
  socket.close
end

sock = Socket.tcp(Socket::Family::INET)
sock.bind "localhost", 1234

sock = Socket.tcp(Socket::Family::INET6)
sock.bind 1234

sock = Socket.udp(Socket::Family::INET)
sock.bind Socket::IPAddress.new("192.168.1.25", 80)

sock = Socket.tcp(Socket::Family::INET)
sock.connect "crystal-lang.org", 80

sock = Socket.unix
sock.connect Socket::UNIXAddress.new("/tmp/service.sock")

server = Socket.udp(Socket::Family::INET)
server.bind("localhost", 1234)

message, client_addr = server.receive

server = Socket.udp(Socket::Family::INET)
server.bind("localhost", 1234)

message = Bytes.new(32)
bytes_read, client_addr = server.receive(message)

server = Socket::IPAddress.new("10.0.3.1", 2022)
sock = Socket.udp(Socket::Family::INET)
sock.connect("example.com", 2000)
sock.send("text query", to: server)

sock = Socket.udp(Socket::Family::INET)
sock.connect("example.com", 2000)
sock.send("text message")

sock = Socket.unix(Socket::Type::DGRAM)
sock.connect Socket::UNIXAddress.new("/tmp/service.sock")
sock.send(Bytes[0])