frago9876543210/ws

Lightweight multithreaded websocket server written in PHP

dev-master 2020-04-02 09:21 UTC

Requires

• php: >=7.3.0
• ext-parallel: >=1.1.3
• ext-sockets: *
• particle/validator: ^2.3
• pocketmine/binaryutils: dev-master
• pocketmine/spl: dev-master

Requires (Dev)

• phpstan/phpstan: ^0.12.18
• phpstan/phpstan-strict-rules: ^0.12.2

MIT

README

Lightweight multithreaded websocket server written in PHP

Requirements

• PHP 7.3+
• ext-parallel

Example

Project tree

├── composer.json
└── src
    ├── MyListener.php
    └── run.php

composer.json:

{
  "require": {
    "frago9876543210/ws": "dev-master",
    "ext-json": "*"
  },
  "autoload": {
    "psr-4": {
      "app\\": "src/"
    }
  },
  "minimum-stability": "dev"
}

src/run.php:

<?php

declare(strict_types=1);

use app\MyListener;
use ws\utils\InternetAddress;
use ws\WebSocket;

require_once "vendor/autoload.php";

new WebSocket(new InternetAddress("0.0.0.0", 8080), "/ws", MyListener::class);

src/MyListener.php:

<?php

declare(strict_types=1);

namespace app;

use JsonException;
use Particle\Validator\Validator;
use ws\Connection;
use ws\EventListener;
use function json_decode;
use const JSON_THROW_ON_ERROR;

class MyListener implements EventListener{

	public function onConnect(Connection $connection) : void{
		echo "+ {$connection->getAddress()}\n";
	}

	public function onMessage(Connection $connection, string $message) : void{
		try{
			$data = json_decode($message, true, 2, JSON_THROW_ON_ERROR);

			$validator = new Validator();
			$validator->required("username")->string();
			$validator->required("message")->string();

			if($validator->validate($data)->isValid()){
				$connection->send($message, true);
				echo "{$data["username"]} ({$connection->getAddress()}): {$data["message"]}\n";
			}else{
				$connection->close("Invalid data provided");
			}
		}catch(JsonException $e){
			$connection->close("Failed to parse json: " . $e->getMessage());
		}
	}

	public function onDisconnect(Connection $connection) : void{
		echo "- {$connection->getAddress()}\n";
	}
}