发表新帖

websocket不知道这样对不对呢

我想要达到的目的是开一个websocket，定时查询数据库，然后有符合条件的记录时，给client端push一个消息，会push两次，何解？
{{{
<?php 
$ws = new swoole_websocket_server("0.0.0.0", 9503);

$ws->on('WorkerStart', function($ws, $worker_id){
	echo 'Server2 started, worker_id:' . $worker_id;
		
	// 定时器，每分钟一次
	$ws->tick(2000, function() use ($ws){
		$db = new swoole_mysql;
		$server = array(
			'host' => '',
			'port' => '',
			'user' => '',
			'password' => '',
			'database' => ''
		);
		$r = $db->connect($server, function($db, $result) use($ws){
			if($result === false){
				var_dump($db->connect_errno, $db->connect_error);
				die;
			}
			echo "connect to mysql server sucess\n";
			$sql = 'select id, created, mailto, mailtitle, mailcontent from mail_notice_cron where type=1';
			$db->query($sql, function(swoole_mysql $db, $r) use($ws){
				global $s;
				if($r === false){
					var_dump($db->error, $db->errno);
				}elseif ($r === true){
					var_dump($db->affected_rows, $db->insert_id);
				}
				echo "count=" . count($r) . ", time=" . (microtime(true) - $s), "\n";
				foreach($r as $cron){
					// 给不同的端发消息
					$start_fd = 0;
					while(true){
						$conn_list = $ws->connection_list($start_fd, 10);
						if($conn_list===false or count($conn_list) === 0) break;
						$start_fd = end($conn_list);
						foreach($conn_list as $fd){
							$ws->push($fd, json_encode($cron));
							echo '发消息给：' . $fd . '，消息内容：' . serialize($cron);
						}						
					}

$db->query("delete from mail_notice_cron where id=" . $cron['id'], function(swoole_mysql $db, $r){
						
					});
				}
				$db->close();
			});
		});
				
	});

});

$ws->on('open', function ($ws, $request) {
    var_dump($request->fd, $request->get, $request->server);
	
    $ws->push($request->fd, "hello, welcome\n");

});

$ws->on('message', function ($ws, $frame) {
    echo "Message: {$frame->data}\n";
    $ws->push($frame->fd, "server: {$frame->data}");
});

$ws->on('close', function ($ws, $fd) {
    echo "client-{$fd} is closed\n";
});

$ws->start();
}}}

会输出
{{{
Server2 started, worker_id:0Server2 started, worker_id:1
var_dump($conn_list); // 也会打印两次
}}}

这是正常的吗？

发布于8年前 · 1 次浏览 · 来自提问

龙

龙想凌。

$db->query("delete from mail_notice_cron where id=" . $cron['id'], function(swoole_mysql $db, $r){
						
					});
				}
				$db->close();
			});
		});
				
	});

});

$ws->on('open', function ($ws, $request) {
    var_dump($request->fd, $request->get, $request->server);
	
    $ws->push($request->fd, "hello, welcome\n");

});

$ws->on('message', function ($ws, $frame) {
    echo "Message: {$frame->data}\n";
    $ws->push($frame->fd, "server: {$frame->data}");
});

$ws->on('close', function ($ws, $fd) {
    echo "client-{$fd} is closed\n";
});

$ws->start();
}}}

会输出
{{{
Server2 started, worker_id:0Server2 started, worker_id:1
var_dump($conn_list); // 也会打印两次
}}}

这是正常的吗？

登录后参与评论

2017-12-25

ghostjialong1988

2018-02-09

华