PHP异步协程开发：构建高可用的在线咨询系统

server 192.168.1.100:80;
server 192.168.1.101:80;
server 192.168.1.102:80;
server 192.168.1.103:80;

listen 80;
server_name chat.example.com;
location / {
    proxy_pass Http://backend;
    proxy_set_header Host $host;
    proxy_set_header X-Real-IP $remote_addr;
    proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
}

<ul>
  <li v-for="(message, index) in messages" :key="index">{{ message }}</li>
</ul>
<input v-model="msg" @keyup.enter="sendMessage">

return {
  ws: null,
  messages: [],
  msg: ''
}

this.initwebsocket()

initWEBSocket () {
  if (this.ws) {
    this.ws.close()
  }
  const url = 'ws://' + window.location.host + '/ws'
  this.ws = new WebSocket(url)
  this.ws.onopen = () => {
    this.addMessage('已连接到聊天服务器')
  }
  this.ws.onmessage = (event) => {
    this.addMessage(event.data)
  }
  this.ws.onclose = () => {
    this.addMessage('聊天服务器已关闭')
    this.ws = null
  }
  this.ws.onerror = (event) => {
    this.addMessage('聊天服务器连接错误')
  }
},
sendMessage () {
  if (!this.msg) {
    return
  }
  if (!this.ws || this.ws.readyState !== WebSocket.OPEN) {
    this.addMessage('无法连接到聊天服务器')
    return
  }
  this.ws.send(this.msg)
  this.addMessage('我: ' + this.msg)
  this.msg = ''
},
addMessage (message) {
  this.messages.push(message)
  this.$nextTick(() => {
    const scrollHeight = this.$el.scrollHeight
    this.$el.scrollTop = scrollHeight
  })
}

echo "connection open: {$request->fd}

echo "received message: {$frame->data}

foreach ($server->connections as $fd) {
    if ($server->isEstablished($fd)) {
        $server->push($fd, $frame->data);
    }
}

echo "connection close: {$fd}

$client = new SwooleCoroutineClient(SWOOLE_SOCK_tcp);
$client->set([
    'open_length_check' => true,
    'package_max_length' => 1024 * 1024,
    'package_length_type' => 'N',
    'package_body_offset' => 4,
]);
$result = $client->connect($host, $port);
if (!$result) {
    throw new Exception('Failed to connect');
}
return $client;

$data = pack('N', strlen($message)) . $message;
$result = $client->send($data);
if (!$result) {
    throw new Exception('Failed to send message');
}
return true;

$result = $client->recv(1024 * 1024, $timeout);
if ($result === '') {
    throw new Exception('Connection closed');
}
if (!$result) {
    throw new Exception('Failed to receive message');
}
$length = unpack('N', substr($result, 0, 4))[1];
$message = trim(substr($result, 4, $length));
return $message;

$cli = new SwooleHttpClient('127.0.0.1', 80);
$cli->set([
    'timeout' => $timeout,
]);
$cli->setHeaders([
    'Host' => 'localhost',
    'User-Agent' => 'swoole-http-client',
    'Accept-Encoding' => 'gzip',
]);
$cli->post($url, [
    'name' => 'swoole',
]);
return $cli;