PHP WebSockets Server Example: Example to interact with a server using WebSockets

Recommend this page to a friend!

Download

Info

Documentation

Files

Install with Composer

Download

Reputation

Support forum

Blog

Links

Ratings				Unique User Downloads		Download Rankings
Not yet rated by the users				Total: 112		All time: 9,623 This week: 51

Version		License		PHP version		Categories
`socket-programming-u` 1.0.0		GNU General Publi...		5		Networking, PHP 5

Description

Author

butani kartik

This package provides example code to interact with a server using a WebSockets client.

It provides classes and example scripts to create interactive applications using Web sockets.

Currently, it provides an example that uses the Ratchet library to handle events of a WebSocket connection when a client connects, when a message is sent, or when a client connection is closed.

butani kartik

Performance

Level

Name:	butani kartik `<contact>`
Classes:	2 packages by butani kartik
Country:	India
Age:	31
All time rank:	4103	281 in India
Week rank:	195	19 in India

Level 1

Recommendations

Capture user fingerprint and save in database
Capture fingerprint from Secgen H20 device in PHP application

Documentation

Socket Programming Using PHP

Here bin folder is contain server file that you can execute on command.
Src folder is contain atual logic on it.
First, Download Ratchet Library file on your pc using composer

composer require cboden/ratchet

Then after Create Our Login File on src folder ( RealTimeData.php )

namespace MyApp;
use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;

class RealTimeData implements MessageComponentInterface {
    protected $clients;

    public function __construct() {
        $this->clients = new \SplObjectStorage;
        //print_r($this->clients);
    }

    public function onOpen(ConnectionInterface $conn) {
        // Store the new connection to send messages to later
        $this->clients->attach($conn);

       // print_r($conn->resourceId);

        echo "RealTime Data New connection! ({$conn->resourceId})\n";
    }

    public function onMessage(ConnectionInterface $from, $msg) {
        $numRecv = count($this->clients) - 1;
        //echo sprintf('Connection %d sending message "%s" to %d other connection%s' . "\n"  , $from->resourceId, $msg, $numRecv, $numRecv == 1 ? '' : 's');
        
        $msg = json_decode($msg);
       //print_r($msg);
        foreach ($this->clients as $client) {
            if ($from === $client) {
                // The sender is not the receiver, send to each client connected
                $client->send(json_encode(array('status'=>"Success")));
            }
        }
    }

    public function onClose(ConnectionInterface $conn) {
        // The connection is closed, remove it, as we can no longer send it messages
        $this->clients->detach($conn);

        echo "Connection {$conn->resourceId} has disconnected\n";
    }

    public function onError(ConnectionInterface $conn, \Exception $e) {
        echo "An error has occurred: {$e->getMessage()}\n";

        $conn->close();
    }
}

After done this thing create server on bin folder ( realtimedata.php )

<?php
use Ratchet\Server\IoServer;
use Ratchet\Http\HttpServer;
use Ratchet\WebSocket\WsServer;
use MyApp\RealTimeData;

    require dirname(__DIR__) . '/vendor/autoload.php';

    $server = IoServer::factory(
        new HttpServer(
            new WsServer(
                new RealTimeData()
            )
        ),
        8080
    );

    $server->run();

Now You call these WebSocket Services ( index.php )

<!DOCTYPE html>
<html>
<head>
    <meta charset="utf-8">
    <title>Hello</title>
</head>
<body>


    <script type="text/javascript">
        // When Single Connection
        var conn = new WebSocket('ws://localhost:8080');
        conn.onopen = function(e) {
            console.log("Connection established!");
            var data = {
                    'name': "kartik",
                    'age': 28,
                    'bio': {
                        'hobi': 'reading',
                        'skill': 'Codding'
                    }
            };
            conn.send(JSON.stringify(data));
        };

        conn.onmessage = function(e) {
            console.log(e.data);
        };

/*
        // you can route multiple socket connection
        var conn = new WebSocket('ws://localhost:8080/home');
        conn.onopen = function(e) {
            console.log("Connection established!");
            var data = {
                    'name': "kartik",
                    'age': 28,
                    'bio': {
                        'hobi': 'reading',
                        'skill': 'Codding'
                    }
            };
            conn.send(JSON.stringify(data));
        };

        conn.onmessage = function(e) {
            console.log(e.data);
        };


        var conn2 = new WebSocket('ws://localhost:8080/realtime');
        conn2.onopen = function(e) {
            console.log("Connection established!");
            var data = {
                    'name': "Its Stock Data",
                    'age': 28,
                    'bio': {
                        'hobi': 'reading',
                        'skill': 'Codding'
                    }
            };
            conn2.send(JSON.stringify(data));
        };

        conn2.onmessage = function(e) {
            console.log(e.data);
        };
*/
    </script>
</body>
</html>

Run Program

Fire following command to run server
php bin/realtimedata.php

then open in browser index.php and see output on console or command line
Auther: krbutani
Contact me if you need More help
Whatsapp: +91 8460304360

Files (500)

File	Role	Description
`bin` (2 files)
`src` (2 files)
`vendor` (1 file, 9 directories)
`composer.json`	Data	Auxiliary data
`composer.lock`	Data	Auxiliary data
`index.php`	Aux.	Auxiliary script
`README.md`	Doc.	Read me

File	Role	Description
`multipleroute.php`	Class	Class source
`realtimedata.php`	Example	Example script

File	Role	Description
`HomePage.php`	Class	Class source
`RealTimeData.php`	Class	Class source

File	Role	Description
`cboden` (1 directory)
`composer` (12 files)
`evenement` (1 directory)
`guzzlehttp` (1 directory)
`psr` (1 directory)
`ralouphie` (1 directory)
`ratchet` (1 directory)
`react` (7 directories)
`symfony` (5 directories)
`autoload.php`	Aux.	Auxiliary script

File	Role	Description
`src` (1 directory)
`tests` (1 file, 3 directories)
`.travis.yml`	Data	Auxiliary data
`CHANGELOG.md`	Data	Auxiliary data
`composer.json`	Data	Auxiliary data
`LICENSE`	Lic.	License text
`Makefile`	Data	Auxiliary data
`phpunit.xml.dist`	Data	Auxiliary data
`README.md`	Class	Class source

File	Role	Description
`Http` (7 files)
`Server` (5 files)
`Session` (1 file, 2 directories)
`Wamp` (8 files)
`WebSocket` (6 files)
`AbstractConnectionDecorator.php`	Class	Class source
`App.php`	Class	Class source
`ComponentInterface.php`	Class	Class source
`ConnectionInterface.php`	Class	Class source
`MessageComponentInterface.php`	Class	Class source
`MessageInterface.php`	Class	Class source

File	Role	Description
`CloseResponseTrait.php`	Class	Class source
`HttpRequestParser.php`	Class	Class source
`HttpServer.php`	Class	Class source
`HttpServerInterface.php`	Class	Class source
`NoOpHttpServerController.php`	Class	Class source
`OriginCheck.php`	Class	Class source
`Router.php`	Class	Class source

File	Role	Description
`EchoServer.php`	Class	Class source
`FlashPolicy.php`	Class	Class source
`IoConnection.php`	Class	Class source
`IoServer.php`	Class	Class source
`IpBlackList.php`	Class	Class source

File	Role	Description
`Serialize` (3 files)
`Storage` (1 file, 1 directory)
`SessionProvider.php`	Class	Class source

File	Role	Description
`HandlerInterface.php`	Class	Class source
`PhpBinaryHandler.php`	Class	Class source
`PhpHandler.php`	Class	Class source

File	Role	Description
`Proxy` (1 file)
`VirtualSessionStorage.php`	Class	Class source

File	Role	Description
`Exception.php`	Class	Class source
`JsonException.php`	Class	Class source
`ServerProtocol.php`	Class	Class source
`Topic.php`	Class	Class source
`TopicManager.php`	Class	Class source
`WampConnection.php`	Class	Class source
`WampServer.php`	Class	Class source
`WampServerInterface.php`	Class	Class source

File	Role	Description
`ConnContext.php`	Class	Class source
`MessageCallableInterface.php`	Class	Class source
`MessageComponentInterface.php`	Class	Class source
`WsConnection.php`	Class	Class source
`WsServer.php`	Class	Class source
`WsServerInterface.php`	Class	Class source

File	Role	Description
`autobahn` (3 files, 1 directory)
`helpers` (1 directory)
`unit` (1 file, 4 directories)
`bootstrap.php`	Example	Example script

File	Role	Description
`bin` (1 file)
`fuzzingclient-all.json`	Data	Auxiliary data
`fuzzingclient-profile.json`	Data	Auxiliary data
`fuzzingclient-quick.json`	Data	Auxiliary data

File	Role	Description
`Mock` (4 files)
`Wamp` (1 directory)
`WebSocket` (1 directory)
`AbstractMessageComponentTestCase.php`	Class	Class source
`NullComponent.php`	Class	Class source

File	Role	Description
`Component.php`	Class	Class source
`Connection.php`	Class	Class source
`ConnectionDecorator.php`	Class	Class source
`WampComponent.php`	Class	Class source

File	Role	Description
`Http` (4 files)
`Server` (5 files)
`Session` (1 file, 2 directories)
`Wamp` (5 files)
`AbstractConnectionDecoratorTest.php`	Class	Class source

File	Role	Description
`HttpRequestParserTest.php`	Class	Class source
`HttpServerTest.php`	Class	Class source
`OriginCheckTest.php`	Class	Class source
`RouterTest.php`	Class	Class source

File	Role	Description
`EchoServerTest.php`	Class	Class source
`FlashPolicyComponentTest.php`	Class	Class source
`IoConnectionTest.php`	Class	Class source
`IoServerTest.php`	Class	Class source
`IpBlackListComponentTest.php`	Class	Class source

File	Role	Description
`Serialize` (1 file)
`Storage` (1 file)
`SessionComponentTest.php`	Class	Class source

File	Role	Description
`ServerProtocolTest.php`	Class	Class source
`TopicManagerTest.php`	Class	Class source
`TopicTest.php`	Class	Class source
`WampConnectionTest.php`	Class	Class source
`WampServerTest.php`	Class	Class source

File	Role	Description
`autoload_classmap.php`	Aux.	Auxiliary script
`autoload_files.php`	Aux.	Auxiliary script
`autoload_namespaces.php`	Aux.	Auxiliary script
`autoload_psr4.php`	Aux.	Auxiliary script
`autoload_real.php`	Class	Class source
`autoload_static.php`	Class	Class source
`ClassLoader.php`	Class	Class source
`installed.json`	Data	Auxiliary data
`installed.php`	Aux.	Auxiliary script
`InstalledVersions.php`	Class	Class source
`LICENSE`	Lic.	License text
`platform_check.php`	Aux.	Auxiliary script

File	Role	Description
`doc` (3 files)
`examples` (5 files)
`src` (1 directory)
`tests` (1 directory)
`.travis.yml`	Data	Auxiliary data
`CHANGELOG.md`	Data	Auxiliary data
`composer.json`	Data	Auxiliary data
`LICENSE`	Lic.	License text
`phpunit.xml.dist`	Data	Auxiliary data
`README.md`	Example	Example script

File	Role	Description
`00-intro.md`	Data	Auxiliary data
`01-api.md`	Data	Auxiliary data
`02-plugin-system.md`	Class	Class source

File	Role	Description
`benchmark-emit-no-arguments.php`	Example	Example script
`benchmark-emit-once.php`	Example	Example script
`benchmark-emit-one-argument.php`	Example	Example script
`benchmark-emit.php`	Example	Example script
`benchmark-remove-listener-once.php`	Example	Example script

File	Role	Description
`EventEmitter.php`	Class	Class source
`EventEmitterInterface.php`	Class	Class source
`EventEmitterTrait.php`	Class	Class source

File	Role	Description
`EventEmitterTest.php`	Class	Class source
`functions.php`	Aux.	Auxiliary script
`Listener.php`	Class	Class source

File	Role	Description
`.github` (1 directory)
`src` (30 files)
`.php_cs.dist`	Example	Example script
`CHANGELOG.md`	Data	Auxiliary data
`composer.json`	Data	Auxiliary data
`LICENSE`	Lic.	License text
`README.md`	Doc.	Documentation

File	Role	Description
`bc.yml`	Data	Auxiliary data
`ci.yml`	Data	Auxiliary data
`integration.yml`	Data	Auxiliary data
`static.yml`	Data	Auxiliary data

File	Role	Description
`AppendStream.php`	Class	Class source
`BufferStream.php`	Class	Class source
`CachingStream.php`	Class	Class source
`DroppingStream.php`	Class	Class source
`FnStream.php`	Class	Class source
`functions.php`	Aux.	Auxiliary script
`functions_include.php`	Aux.	Auxiliary script
`Header.php`	Class	Class source
`InflateStream.php`	Class	Class source
`LazyOpenStream.php`	Class	Class source
`LimitStream.php`	Class	Class source
`Message.php`	Class	Class source
`MessageTrait.php`	Class	Class source
`MimeType.php`	Class	Class source
`MultipartStream.php`	Class	Class source
`NoSeekStream.php`	Class	Class source
`PumpStream.php`	Class	Class source
`Query.php`	Class	Class source
`Request.php`	Class	Class source
`Response.php`	Class	Class source
`Rfc7230.php`	Class	Class source
`ServerRequest.php`	Class	Class source
`Stream.php`	Class	Class source
`StreamDecoratorTrait.php`	Class	Class source
`StreamWrapper.php`	Class	Class source
`UploadedFile.php`	Class	Class source
`Uri.php`	Class	Class source
`UriNormalizer.php`	Class	Class source
`UriResolver.php`	Class	Class source
`Utils.php`	Class	Class source