RError.com

RError.com Logo RError.com Logo

RError.com Navigation

  • 主页

Mobile menu

Close
  • 主页
  • 系统&网络
    • 热门问题
    • 最新问题
    • 标签
  • Ubuntu
    • 热门问题
    • 最新问题
    • 标签
  • 帮助
主页 / 问题 / 1153992
Accepted
Moonwolf45
Moonwolf45
Asked:2020-07-17 19:35:20 +0000 UTC2020-07-17 19:35:20 +0000 UTC 2020-07-17 19:35:20 +0000 UTC

Yii2 和棘轮问题

  • 772

一般来说,我在套接字上编写聊天,或者更确切地说,我尝试使用棘轮为套接字进行。而且问题是发送消息时什么都没有发生,很可能是socket端的onMessage方法不起作用。这是js代码:

let websocketServerLocation = 'ws://localhost:9095/web-chat'; //название экшена должен совпадать с route в запускаемом через консоль экшене

let chat = null;
function socketStart(websocketServerLocation) {
    chat = new WebSocket(websocketServerLocation);

    chat.onmessage = function(e) {
        let response = JSON.parse(e.data);
        console.log(response);
    };

    chat.onerror = function(e) {
        console.warn('Возникла ошибка');
        chat.close();
    };

    chat.onclose = function() {
        console.warn('Попытка подключения...');

        setTimeout(function() {
            socketStart(websocketServerLocation)
        }, 5000);
    };

    chat.onopen = function(e) {
        console.log('Вы онлайн');
    };

    $('.new-message-form').submit(function (e) {
        e.preventDefault();

        let text = $('#textMessage').val();
        let only = 0;

        if ($('#onlyForAdmin').prop('checked') === true) {
            only = 1;
        }
        //
        $('#textMessage').val();
        $('#onlyForAdmin').prop('checked', false);

        let message = { id: chat_id, guid: chatGuid, web_id: webinarID, name: currentName, type: 0, only: only,
            time: new Date(), text: text };
        console.log(message);

        if (chat.readyState === chat.OPEN) {
            // Если соедение не открыто
            chat.send(message);
            addMessage(message);
        } else {
            console.warn('WS NOT CONNECTED');
        }
    });
}

这个函数的启动在代码下面,但是因为 太大了,我就不放了。这是套接字代码:

class Chat implements MessageComponentInterface {

protected $clients;

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

public function onOpen (ConnectionInterface $conn) {
    // Сохраните новое соединение для отправки сообщений позже
    $this->clients->attach($conn);

    echo "New connection: " . $conn->resourceId . "\n";
}

public function onMessage (ConnectionInterface $from, $msg) {
    Yii::info($from);

    $current_client = $this->findConnection($from);

    Yii::info($current_client);

    $request = json_decode($msg, true);
    $result = null;

    Yii::info($request);

    if (!empty($request['text']) && $message = trim($request['text'])) {
        // Здесь можно сохранять сообщения в БД
        $saved_message = Dialogs::saveMessage($request['id'], $request['guid'], $request['web_id'],
            $request['name'], $request['type'], $request['only'], $request['time'], $message);

        $result = $saved_message;

        if ($result !== null) {
            foreach ($this->clients as $client) {
//                    if ($from != $client) {
                    $client->send(json_encode([
                        'from' => $current_client->name,
                        'date' => date( 'H:i', $result->created_at ),
                        'message' => $message,
                    ]));
//                    }
            }
        } else {
            // Выводит сообщение если при сохранении возникли ошибки
            $result = $saved_message;
        }
    }

    $from->send(json_encode($result));
}

public function onClose (ConnectionInterface $conn) {
    // Соединение закрыто, удалите его, так как мы больше не можем отправлять ему сообщения.
    $this->clients->detach($conn);

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

public function onError (ConnectionInterface $conn, \Exception $e) {
    echo "Произошла ошибка: " . $e->getMessage() . "\n";

    $conn->close();
}

public function findConnection( ConnectionInterface $conn ) {
    // Ищем пользователя, который написал
    foreach ($this->clients as $client) {
        if ($client->connection === $conn) {
            return $client;
        }
    }
    return null;
}
}

如您所见,我正在尝试记录一些数据,但它没有出现在日志中。套接字调用代码:

public function actionStart() {
    $app = new RatchetApp('localhost', 9095);
//        $app = new App('localhost', 9095);
    $app->route('/web-chat', new Chat(), ['*']);
    $app->run();
}

顺便说一句,RatchetApp创建该类是为了解决 xDebug 的错误。这是他的代码:

class RatchetApp extends App {
/**
 * RatchetApp constructor.
 * @param string $httpHost
 * @param int $port
 * @param string $address
 * @param LoopInterface $loop
 */
public function __construct(string $httpHost = 'localhost', int $port = 8080, string $address = '127.0.0.1',
    LoopInterface $loop = null) {
        @parent::__construct($httpHost, $port, $address, $loop);
}
}
yii2
  • 1 1 个回答
  • 10 Views

1 个回答

  • Voted
  1. Best Answer
    Moonwolf45
    2020-07-17T21:25:43Z2020-07-17T21:25:43Z

    我发现了问题所在,所有内容都只需要在将消息发送到服务器之前包装在 json 中,如下所示:

    if (chat.readyState === chat.OPEN) {
            // Если соедение не открыто
            chat.send(JSON.stringify(message));
            addMessage(message);
        } else {
            console.warn('WS NOT CONNECTED');
        }
    }
    
    • 0

相关问题

  • 为什么有些文件上传到服务器时验证失败,为什么不报错?

  • Yii2-如何在 URL 中存储 $_GET 名称

  • 如何在网站的公共部分禁用 Bootstrap,但将其保留在管理员中?

  • 如何使用数据库中的值进行自动注销

Sidebar

Stats

  • 问题 10021
  • Answers 30001
  • 最佳答案 8000
  • 用户 6900
  • 常问
  • 回答
  • Marko Smith

    如何从列表中打印最大元素(str 类型)的长度?

    • 2 个回答
  • Marko Smith

    如何在 PyQT5 中清除 QFrame 的内容

    • 1 个回答
  • Marko Smith

    如何将具有特定字符的字符串拆分为两个不同的列表?

    • 2 个回答
  • Marko Smith

    导航栏活动元素

    • 1 个回答
  • Marko Smith

    是否可以将文本放入数组中?[关闭]

    • 1 个回答
  • Marko Smith

    如何一次用多个分隔符拆分字符串?

    • 1 个回答
  • Marko Smith

    如何通过 ClassPath 创建 InputStream?

    • 2 个回答
  • Marko Smith

    在一个查询中连接多个表

    • 1 个回答
  • Marko Smith

    对列表列表中的所有值求和

    • 3 个回答
  • Marko Smith

    如何对齐 string.Format 中的列?

    • 1 个回答
  • Martin Hope
    Alexandr_TT 2020年新年大赛! 2020-12-20 18:20:21 +0000 UTC
  • Martin Hope
    Alexandr_TT 圣诞树动画 2020-12-23 00:38:08 +0000 UTC
  • Martin Hope
    Air 究竟是什么标识了网站访问者? 2020-11-03 15:49:20 +0000 UTC
  • Martin Hope
    Qwertiy 号码显示 9223372036854775807 2020-07-11 18:16:49 +0000 UTC
  • Martin Hope
    user216109 如何为黑客设下陷阱,或充分击退攻击? 2020-05-10 02:22:52 +0000 UTC
  • Martin Hope
    Qwertiy 并变成3个无穷大 2020-11-06 07:15:57 +0000 UTC
  • Martin Hope
    koks_rs 什么是样板代码? 2020-10-27 15:43:19 +0000 UTC
  • Martin Hope
    Sirop4ik 向 git 提交发布的正确方法是什么? 2020-10-05 00:02:00 +0000 UTC
  • Martin Hope
    faoxis 为什么在这么多示例中函数都称为 foo? 2020-08-15 04:42:49 +0000 UTC
  • Martin Hope
    Pavel Mayorov 如何从事件或回调函数中返回值?或者至少等他们完成。 2020-08-11 16:49:28 +0000 UTC

热门标签

javascript python java php c# c++ html android jquery mysql

Explore

  • 主页
  • 问题
    • 热门问题
    • 最新问题
  • 标签
  • 帮助

Footer

RError.com

关于我们

  • 关于我们
  • 联系我们

Legal Stuff

  • Privacy Policy

帮助

© 2023 RError.com All Rights Reserve   沪ICP备12040472号-5