nanonext (version 0.5.4)

socket: Open Socket

Description

Open a Socket implementing 'protocol', and optionally dial (establish an outgoing connection) or listen (accept an incoming connection) at an address.

Usage

socket(
  protocol = c("bus", "pair", "push", "pull", "pub", "sub", "req", "rep", "surveyor",
    "respondent"),
  dial = NULL,
  listen = NULL,
  autostart = TRUE,
  raw = FALSE
)

Value

A Socket (object of class 'nanoSocket' and 'nano').

Arguments

protocol

[default 'bus'] choose protocol - 'bus', 'pair', 'push', 'pull', 'pub', 'sub', 'req', 'rep', 'surveyor', or 'respondent' - see protocols.

dial

(optional) a URL to dial, specifying the transport and address as a character string e.g. 'inproc://anyvalue' or 'tcp://127.0.0.1:5555' (see transports).

listen

(optional) a URL to listen at, specifying the transport and address as a character string e.g. 'inproc://anyvalue' or 'tcp://127.0.0.1:5555' (see transports).

autostart

[default TRUE] whether to start the dialer/listener. Set to FALSE if you wish to set configuration options on the dialer/listener as it is not generally possible to change these once started.

raw

[default FALSE] whether to open raw mode sockets. Note: not for general use - do not enable unless you have a specific need, such as for use with device (refer to NNG documentation).

Protocols

The following Scalability Protocols (communication patterns) are implemented:

• Bus (mesh networks) - protocol: 'bus'

• Pair (two-way radio) - protocol: 'pair'

• Pipeline (one-way pipe) - protocol: 'push', 'pull'

• Publisher/Subscriber (topics & broadcast) - protocol: 'pub', 'sub'

• Request/Reply (RPC) - protocol: 'req', 'rep'

• Survey (voting & service discovery) - protocol: 'surveyor', 'respondent'

Please see protocols for further documentation.

Details

NNG presents a socket view of networking. The sockets are constructed using protocol-specific functions, as a given socket implements precisely one protocol.

Each socket may be used to send and receive messages (if the protocol supports it, and implements the appropriate protocol semantics). For example, sub sockets automatically filter incoming messages to discard those for topics that have not been subscribed.

This function (optionally) binds a single Dialer and/or Listener to a Socket. More complex network topologies may be created by binding further Dialers/Listeners to the Socket as required using dial and listen. New contexts can also be created using context if the protocol supports it.

Examples

socket <- socket("pair")
socket
close(socket)