The middleman is the main component of the I/O module and enables distribution. It transparently manages proxy actor instances representing remote actors, maintains connections to other nodes, and takes care of serialization of messages. Applications install a middleman by loading caf::io::middleman as module (see § :ref:`system-config <#system-config>`__). Users can include "caf/io/all.hpp" to get access to all public classes of the I/O module.

Class middleman

expected<uint16> open(uint16, c onst char*, bool) See § 1.2.
expected<uint16> publish(T, uin t16, const char*, bool) See § 1.2.
expected<void> unpublish(T x, u int16) See § 1.2.
expected<node_id> connect(std:: string host, uint16_t port) See § 1.2.
expected<T> remote_actor<T = ac tor>(string, uint16) See § 1.2.
``expected<T> spawn_broker(F fun,
See § :ref:`broker <#broker>` __.
expected<T> spawn_client(F, str ing, uint16, ...) See § :ref:`broker <#broker>` __.
expected<T> spawn_server(F, uin t16, ...) See § :ref:`broker <#broker>` __.

Publishing and Connecting

The member function publish binds an actor to a given port, thereby allowing other nodes to access it over the network.

template <class T>
expected<uint16_t> middleman::publish(T x, uint16_t port,
                                      const char* in = nullptr,
                                      bool reuse_addr = false);

The first argument is a handle of type actor or typed_actor<...>. The second argument denotes the TCP port. The OS will pick a random high-level port when passing 0. The third parameter configures the listening address. Passing null will accept all incoming connections (INADDR_ANY). Finally, the flag reuse_addr controls the behavior when binding an IP address to a port, with the same semantics as the BSD socket flag SO_REUSEADDR. For example, with reuse_addr = false, binding two sockets to and will fail with EADDRINUSE since includes With reuse_addr = true binding would succeed because and are not literally equal addresses.

The member function returns the bound port on success. Otherwise, an error (see § :ref:`error <#error>`__) is returned.

template <class T>
expected<uint16_t> middleman::unpublish(T x, uint16_t port = 0);

The member function unpublish allows actors to close a port manually. This is performed automatically if the published actor terminates. Passing 0 as second argument closes all ports an actor is published to, otherwise only one specific port is closed.

The function returns an error (see § :ref:`error <#error>`__) if the actor was not bound to given port.

template<class T = actor>
expected<T> middleman::remote_actor(std::string host, uint16_t port);

After a server has published an actor with publish, clients can connect to the published actor by calling remote_actor:

// node A
auto ping = spawn(ping);
system.middleman().publish(ping, 4242);

// node B
auto ping = system.middleman().remote_actor("node A", 4242);
if (! ping) {
  cerr << "unable to connect to node A: "
       << system.render(ping.error()) << std::endl;
} else {
  self->send(*ping, ping_atom::value);

There is no difference between server and client after the connection phase. Remote actors use the same handle types as local actors and are thus fully transparent.

The function pair open and connect allows users to connect CAF instances without remote actor setup. The function connect returns a node_id that can be used for remote spawning (see § :ref:`remote-spawn <#remote-spawn>`__).

Free Functions

The following free functions in the namespace caf::io avoid calling the middleman directly. This enables users to easily switch between communication backends as long as the interfaces have the same signatures. For example, the (experimental) OpenSSL binding of CAF implements the same functions in the namespace caf::openssl to easily switch between encrypted and unencrypted communication.

ll expected<uint16> open(actor_system&, uint16, const char*, bool) & See § 1.2.
expected<uint16> publish(T, uint16, const char*, bool) & See § 1.2.
expected<void> unpublish(T x, uint16) & See § 1.2.
expected<node_id> connect(actor_system&, std::string host, uint16_t port) & See § 1.2.
expected<T> remote_actor<T = actor>(actor_system&, string, uint16) & See § 1.2.