SocketConnect

SocketConnect[address]

makes a socket connection to the TCP host at the specified address and returns a SocketObject representing the connection.

SocketConnect[address,"protocol"]

makes a connection to the host at address with the specified protocol.

SocketConnect[socket]

makes a connection to a local socket opened in the current session.

Details

  • Possible socket addresses include:
  • {host,port}hostname or IP address and port number
    {host,"service"}hostname or IP address and service name
    "host:port"hostname or IP address with port
    portlocal socket localhost:port
    URL["url"] or "url"complete URL (e.g. http://www.wolfram.com)
  • Supported protocols include:
  • "TCP"raw TCP stream protocol
    "ZMQ"ZeroMQ one-to-one message protocol
    {"ZMQ","type"}ZeroMQ protocol of the specified type
  • For ZMQ sockets, possible types include:
  • "Pair"socket that can send/receive with exactly one client peer
    "Publish"socket that sends messages out to all connected clients
    "Subscribe"socket that receives messages from a publisher socket
    "Request"socket to send request messages to a corresponding reply socket and receive response messages
    "Reply"socket to receive request messages from a corresponding "Request" socket and send response messages back
    "Dealer"same as "Request" socket except sent messages are delivered in round-robin style to all connected clients
    "Router"same as "Reply" socket except messages are received in fair-queueing style from all connected clients and maintain routing information
    "Pull"socket for pipeline topologies to receive messages
    "Push"socket for pipeline topologies to send messages
    "XPublish"same as "Publish", but received messages on this socket are subscriptions
    "XSubscribe"same as "Subscribe", but messages sent over this socket are used as subscriptions to the corresponding "XPublish" socket
    "Stream"socket for connecting a ZMQ socket to non-ZMQ TCP sockets
  • With no ZMQ protocol type specified, the underlying socket is a "Pair" socket.
  • Hostnames have forms like "www.wolfram.com".
  • IP addresses can be given as "140.177.0.0" or IPAddress[string], where string is an IPv4 or IPv6 IP address.
  • When the address is given as a URL with no port number specified, the port number is deduced from the URL scheme (e.g. port 80 for http).
  • SocketConnect[SocketObject[…]] can be used to connect to a local socket opened by SocketOpen.
  • Close can be used to close a connection opened by SocketConnect.

Examples

open allclose all

Basic Examples  (2)

Open a connection to a server specified by a URL:

Write a basic HTTP request to the socket:

Read the entire response as a string:

Display the result, without extra newlines:

Close the socket connection:

Open a ZMQ socket:

Connect to the socket:

Send a string to the server socket:

Read the string from the client socket:

Convert the ByteArray to a string:

Close the sockets:

Scope  (1)

Open a ZMQ socket on an available port:

Connect to the socket, manually specifying the port:

Send any expression to the server socket:

Read the expression from the client socket:

Send a list of expressions to the server socket:

Read the expressions from the client socket:

Close the sockets:

Applications  (1)

This example demonstrates the use of a ZMQ publish-subscribe model where a single server broadcasts messages and multiple clients receive these messages. For simplicity, this example runs both the publisher and the multiple subscribers in the same Wolfram Engine process. Typically, the publisher and the subscribers are running in different processes and/or on different machines.

Open a socket for the publisher:

Connect multiple subscribers to the publisher:

Ensure that all subscribers are listening to all messages:

No messages have been sent yet, so the subscribers are not ready to read anything:

Send a message from the publisher:

Now the subscribers are ready to read the message:

Read the message with all the subscribers:

Convert the resulting byte arrays into strings:

Close the publisher and the subscriber sockets:

Possible Issues  (2)

ReadString only works on TCP sockets, as ReadString will wait until the socket is closed by the server before returning the data. ZMQ sockets are never closed by the server and so thus block indefinitely.

Open a ZMQ socket and connect a client:

Write a message to the server and close it:

ReadString now will block indefinitely:

Close the client socket:

When using TCP server sockets opened with SocketOpen, the connection must be closed before ReadString will return.

Open a TCP socket and connect a client:

Write a message to the remote client and close the server:

ReadString now will block indefinitely as the socket hasn't been closed yet:

Closing the remote socket will force ReadString to return:

Close the sockets:

Wolfram Research (2015), SocketConnect, Wolfram Language function, https://reference.wolfram.com/language/ref/SocketConnect.html (updated 2017).

Text

Wolfram Research (2015), SocketConnect, Wolfram Language function, https://reference.wolfram.com/language/ref/SocketConnect.html (updated 2017).

CMS

Wolfram Language. 2015. "SocketConnect." Wolfram Language & System Documentation Center. Wolfram Research. Last Modified 2017. https://reference.wolfram.com/language/ref/SocketConnect.html.

APA

Wolfram Language. (2015). SocketConnect. Wolfram Language & System Documentation Center. Retrieved from https://reference.wolfram.com/language/ref/SocketConnect.html

BibTeX

@misc{reference.wolfram_2024_socketconnect, author="Wolfram Research", title="{SocketConnect}", year="2017", howpublished="\url{https://reference.wolfram.com/language/ref/SocketConnect.html}", note=[Accessed: 22-November-2024 ]}

BibLaTeX

@online{reference.wolfram_2024_socketconnect, organization={Wolfram Research}, title={SocketConnect}, year={2017}, url={https://reference.wolfram.com/language/ref/SocketConnect.html}, note=[Accessed: 22-November-2024 ]}