欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  后端开发

php使用swoole实现一个简单的多人在线聊天群发,swoole在线聊天_PHP教程

程序员文章站 2024-01-14 14:29:58
...

php使用swoole实现一个简单的多人在线聊天群发,swoole在线聊天

聊天逻辑的好多细节没有实现,只实现群发。

php代码:

$serv = new swoole_websocket_server("127.0.0.1",3999);

//服务的基本设置
$serv->set(array(
		'worker_num' => 2,
		'reactor_num'=>8,
		'task_worker_num'=>1,
		'dispatch_mode' => 2,
		'debug_mode'=> 1,
		'daemonize' => true,
		'log_file' => __DIR__.'/log/webs_swoole.log',
		'heartbeat_check_interval' => 60,
		'heartbeat_idle_time' => 600,
));

$serv->on('connect', function ($serv,$fd){
// 	echo "client:$fd Connect.".PHP_EOL;
});

//测试receive
$serv->on("receive",function(swoole_server $serv,$fd,$from_id,$data){
// 	echo "receive#{$from_id}: receive $data ".PHP_EOL;
});

$serv->on('open', function($server, $req) {
// 	echo "server#{$server->worker_pid}: handshake success with fd#{$req->fd}".PHP_EOL;;
// 	echo PHP_EOL;
});

$serv->on('message',function($server,$frame) {
// 	echo "message: ".$frame->data.PHP_EOL;
	$msg=json_decode($frame->data,true);
	switch ($msg['type']){
		case 'login':
			$server->push($frame->fd,"欢迎欢迎~");
			break;
		default:
			break;
	}
	$msg['fd']=$frame->fd;
	$server->task($msg);
});

$serv->on("workerstart",function($server,$workerid){
// 	echo "workerstart: ".$workerid.PHP_EOL;
// 	echo PHP_EOL;
});

$serv->on("task","on_task");
$serv->on("finish",function($serv,$task_id,$data){
	return ;
});
$serv->on('close', function($server,$fd,$from_id) {
// 	echo "connection close: ".$fd.PHP_EOL;
// 	echo PHP_EOL;
});

$serv->start();
function on_task($serv,$task_id,$from_id,$data) {
	switch ($data['type']){
		case 'login':
			$send_msg="说:我来了~";
			break;
		default:
			$send_msg="说:{$data['msg']['speak']}";
			break;
	}
	foreach ($serv->connections as $conn){
		if ($conn!=$data['fd']){
			if (strpos($data['msg']['name'],"游客")===0){
				$name=$data['msg']['name']."_".$data['fd'];
			}else{
				$name=$data['msg']['name'];
			}
		}else{
			$name="我";
		}
		$serv->push($conn,$name.$send_msg);
	}
	return;
}

function on_finish($serv,$task_id,$data){
	return true;
}

  

前端代码:



WebSocket测试

WebSocket Test

昵称:

www.bkjia.comtruehttp://www.bkjia.com/PHPjc/1093100.htmlTechArticlephp使用swoole实现一个简单的多人在线聊天群发,swoole在线聊天 聊天逻辑的好多细节没有实现,只实现群发。 php代码: $serv = new swoole_webso...
相关标签: php

上一篇: PHP 优于 Node.js 的五大理由

下一篇: