OBSOLETE clue/connection-manager

Async ConnectionManager to open TCP/IP and SSL/TLS based connections in a non-blocking fashion

Warning, package is obsolete!

This library was created as an effort to standardize creating connections in reactphp. Now that it's been merged into v0.3.0, a standalone package is no longer needed. Upgrade your code to use React\SocketClient\Connector instead!

Upgrade your composer.json to require "react/socket-client": "0.3.*" instead.

This page is left here for reference and will be removed eventually!

Introduction

Think of this library as an async (non-blocking) version of fsockopen() or stream_socket_client().

Before you can actually transmit and receive data to/from a remote server, you have to establish a connection to the remote end. Establishing this connection through the internet/network takes some time as it requires several steps in order to complete:

1. Resolve remote target hostname via DNS (+cache)
2. Complete TCP handshake (2 roundtrips) with remote target IP:port
3. Optionally enable SSL/TLS on the new resulting connection

This project is built on top of reactphp. It started as a proof of concept and as such takes alot of inspiration from react's sub-projects and aims for a tighter integration back into react's core eventually.

Usage

In order to use this project, you'll need the following react boilerplate code to initialize the main loop and select your DNS server if you have not already set it up anyway.

$loop = React\EventLoop\Factory::create();

$dnsResolverFactory = new React\Dns\Resolver\Factory();
$dns = $dnsResolverFactory->createCached('8.8.8.8', $loop);

Async TCP/IP connections

The ConnectionManager\ConnectionManager provides a single promise-based getConnection($host, $ip) method which resolves as soon as the connection succeeds or fails.

$connectionManager = new ConnectionManager\ConnectionManager($loop, $dns);

$connectionManager->getConnection('www.google.com', 80)->then(function (React\Stream\Stream $stream) {
    $stream->write('...');
    $stream->close();
});

Async SSL/TLS connections

The ConnectionManager\SecureConnectionManager class decorates a given ConnectionManager\ConnectionManager instance by enabling SSL/TLS encryption as soon as the raw TCP/IP connection succeeds. It provides the same promise-based getConnection($host, $ip) method which resolves with a Stream instance that can be used just like any non-encrypted stream.

$secureConnectionManager = new ConnectionManager\SecureConnectionManager($connectionManager, $loop);

$secureConnectionManager->getConnection('www.google.com', 443)->then(function (React\Stream\Stream $stream) {
    $stream->write("GET / HTTP/1.0\r\nHost: www.google.com\r\n\r\n");
    ...
});

Async UDP connections

UDP is a simple connectionless and message-based protocol and thus has no concept such as a "connection" - you can simply send / receive datagrams and as such nothing can block.

License

MIT