当前位置：首页 > 软件库 > Web应用开发 > WebSocket开发包 >

websocket-server

授权协议 MIT License

开发语言 PHP

所属分类 Web应用开发、 WebSocket开发包

软件类型开源软件

地区不详

投递者柯英奕

操作系统跨平台

开源组织无

适用人群未知

软件概览

Websocket Server

This library provides a Request Handler to easily handle Websocketconnections using amphp/http-server.

Installation

This package can be installed as a Composer dependency.

composer require amphp/websocket-server

Currently this library is undergoing a RC phase on a push to 2.0! Please check out the 2.0 RC and let us know if you have any feedback.

Documentation

The documentation for this library is currently a work in progress. Pull Requests to improve the documentation are always welcome!

Requirements

PHP 7.2+

Example

<?php

// Note that this example requires:
// amphp/http-server-router
// amphp/http-server-static-content
// amphp/log

use Amp\Http\Server\HttpServer;
use Amp\Http\Server\Request;
use Amp\Http\Server\Response;
use Amp\Http\Server\Router;
use Amp\Http\Server\StaticContent\DocumentRoot;
use Amp\Log\ConsoleFormatter;
use Amp\Log\StreamHandler;
use Amp\Loop;
use Amp\Promise;
use Amp\Socket\Server;
use Amp\Success;
use Amp\Websocket\Client;
use Amp\Websocket\Message;
use Amp\Websocket\Server\ClientHandler;
use Amp\Websocket\Server\Gateway;
use Amp\Websocket\Server\Websocket;
use Monolog\Logger;
use function Amp\ByteStream\getStdout;
use function Amp\call;

require __DIR__ . '/vendor/autoload.php';

$websocket = new Websocket(new class implements ClientHandler {
    private const ALLOWED_ORIGINS = [
        'http://localhost:1337',
        'http://127.0.0.1:1337',
        'http://[::1]:1337'
    ];
    
    public function handleHandshake(Gateway $gateway, Request $request, Response $response): Promise
    {
        if (!\in_array($request->getHeader('origin'), self::ALLOWED_ORIGINS, true)) {
            return $gateway->getErrorHandler()->handleError(403);
        }

        return new Success($response);
    }

    public function handleClient(Gateway $gateway, Client $client, Request $request, Response $response): Promise
    {
        return call(function () use ($gateway, $client): \Generator {
            while ($message = yield $client->receive()) {
                \assert($message instanceof Message);
                $gateway->broadcast(\sprintf(
                    '%d: %s',
                    $client->getId(),
                    yield $message->buffer()
                ));
            }
        });
    }
});

Loop::run(function () use ($websocket): Promise {
    $sockets = [
        Server::listen('127.0.0.1:1337'),
        Server::listen('[::1]:1337'),
    ];

    $router = new Router;
    $router->addRoute('GET', '/broadcast', $websocket);
    $router->setFallback(new DocumentRoot(__DIR__ . '/public'));

    $logHandler = new StreamHandler(getStdout());
    $logHandler->setFormatter(new ConsoleFormatter);
    $logger = new Logger('server');
    $logger->pushHandler($logHandler);

    $server = new HttpServer($sockets, $router, $logger);

    return $server->start();
});

使用案例

【tio-websocket】3、tio-websocket-server实现任何地方都能对用户发送消息

上一篇文章中，咱们已经成功搭建了咱们的 websocket 服务器，并能够与服务器之间成功通信，本篇文章将带领大家实现任何地方都能对用户发送消息 1、原理解析 tio-websocket-server 中对用户发送消息的方法如下： Tio.sendToUser(channelContext.tioConfig, userId, wsResponse); channelContext.tioCon
WebSocketServer 服务端 c#

using System; using System.Collections.Generic; using System.Windows.Forms; using Newtonsoft.Json; using WebSocketSharp; using WebSocketSharp.Server; namespace PrintPlugin { public partial class
c# websocketServer

代码： https://github.com/AltairCA/.netcore2.0-websocketServerExample 查找安装：WebSocketSharp 解析包：这个可以： /// <summary> /// 解析客户端发送来的数据 /// </summary> /// <returns>The data.</returns> /// <param name="recByt
JAVA: Java.lang.IllegalStateException javax.websocket.server.ServerContainer not availableJ

1、错误信息在使用springboot单元测试出现： Caused by: java.lang.IllegalStateException: javax.websocket.server.ServerContainer not available at org.springframework.util.Assert.state(Assert.java:73) at org.springfra
停止websockets.serve创建的websocket服务器

server.py #!/usr/bin/env python3 import asyncio import websockets class App: def __init__(self): self._task = None self._slots = [] async def worker(self, websocket, path):
java实现websocket server/client

最近在项目中有一个场景，在内网的应用需要接受外网应用的指令。有两种解决方案： 1.内网应用轮询外网应用，http请求指令 2.内网应用与外网应用之间建立websocket长连接记录一下websocket server/client的java实现一、websocket server @Configuration public class WebSocketConfig extends Confi
解决：javax.websocket.server.ServerContainer not available 报错问题

1、问题描述在 SpringBoot 项目中集成了 WebSocket，当进行 SpringBoot 单元测试时报错： javax.websocket.server.ServerContainer not available 报错的方法是： @Bean public ServerEndpointExporter serverEndpointExporter(){ re
ws搭建websocket服务器

ws搭建websocket服务器 ws模块安装 npm install ws ws官方 uuid模块安装 npm install uuid uuid官方 //搭建ws服务器 const WebSocket = require('ws'); const WebSocketServer = require('ws').Server; const wss = new WebSocke
javax.websocket.server.ServerContainer not available 报错

因为这个错误我花费了一下午的时间，就是为了在 springboot 中集成websocket 太难的网上大多数的回答都是测试时报错，我是启动时报错，废话不说了，直接进入主题环境情况 springboot：2.2.13 acitiviti6 websocket 2.报错信息 org.springframework.beans.factory.BeanCreationException: Erro
Android App创建websocket server，App创建websocket服务器，App连接websocket

使用okhttp连接websocket 1、引入okhttp库 implementation 'com.squareup.okhttp3:okhttp:3.11.0' 2、布局文件 <?xml version="1.0" encoding="utf-8"?> <androidx.constraintlayout.widget.ConstraintLayout xmlns:android="http

websocket-server

Websocket Server

Installation

Documentation

Requirements

Example

同类工具

相关阅读

相关文章

相关问答

相关文档