本文整理汇总了PHP中stream_socket_get_name函数的典型用法代码示例。如果您正苦于以下问题:PHP stream_socket_get_name函数的具体用法?PHP stream_socket_get_name怎么用?PHP stream_socket_get_name使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了stream_socket_get_name函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的PHP代码示例。
示例1: onConnectedEvent
public function onConnectedEvent($connSocket, $events, $arg)
{
$connId = $arg[0];
Debug::netEvent(get_class($this) . '::' . __METHOD__ . '(' . $connId . ') invoked. ');
//处理两种状态,一种是直接连接成功,一种是异步通知
if (isset($this->checkConnEvPool[$connId])) {
// 异步通知
// 因为 注册 EV_WRITE 事件是非持久模式的,所以这里不用 delete, 只需要 unset pool 即可
unset($this->checkConnSocketPool[$connId]);
unset($this->checkConnEvPool[$connId]);
}
$evBuf = event_buffer_new($connSocket, array($this, 'onEvBufReadEvent'), array($this, 'onEvBufWriteEvent'), array($this, 'onEventEvent'), array($connId));
event_buffer_base_set($evBuf, daemon::$eventBase);
event_buffer_priority_set($evBuf, 10);
event_buffer_watermark_set($evBuf, EV_READ, $this->evBufLowMark, $this->evBufHighMark);
if (!event_buffer_enable($evBuf, EV_READ | EV_WRITE | EV_PERSIST)) {
Debug::netErrorEvent(get_class($this) . '::' . __METHOD__ . ': can not set base of buffer. #' . $connId);
// socket_close($connSocket);
fclose($connSocket);
return;
}
// 调试这里时,浪费了很多时间,必须注意的是,以上 event 所用的变量如果在函数中,如果没有交给其他的变量引用,在函数结束时就会销毁,
// 造成连接直接断或者bufferevent 不能触发。晕啊晕。
$this->connSocketPool[$connId] = $connSocket;
$this->connEvBufPool[$connId] = $evBuf;
list($ip, $port) = explode(':', stream_socket_get_name($connSocket, true));
$this->updateLastContact($connId);
$this->onConnected($connId, $ip, $port);
}
开发者ID:ansendu,项目名称:ansio,代码行数:29,代码来源:AsyncClient.php
示例2: connect
/**
* Sets up the stream connection
*
* @throws PhpAmqpLib_Exception_AMQPRuntimeException
* @throws Exception
*/
public function connect()
{
$errstr = $errno = null;
$remote = sprintf('%s://%s:%s', $this->protocol, $this->host, $this->port);
set_error_handler(array($this, 'error_handler'));
$this->sock = stream_socket_client($remote, $errno, $errstr, $this->connection_timeout, STREAM_CLIENT_CONNECT, $this->context);
restore_error_handler();
if (false === $this->sock) {
throw new PhpAmqpLib_Exception_AMQPRuntimeException(sprintf('Error Connecting to server(%s): %s ', $errno, $errstr), $errno);
}
if (false === stream_socket_get_name($this->sock, true)) {
throw new PhpAmqpLib_Exception_AMQPRuntimeException(sprintf('Connection refused: %s ', $remote));
}
list($sec, $uSec) = PhpAmqpLib_Helper_MiscHelper::splitSecondsMicroseconds($this->read_write_timeout);
if (!stream_set_timeout($this->sock, $sec, $uSec)) {
throw new PhpAmqpLib_Exception_AMQPIOException('Timeout could not be set');
}
// php cannot capture signals while streams are blocking
if ($this->canDispatchPcntlSignal) {
stream_set_blocking($this->sock, 0);
stream_set_write_buffer($this->sock, 0);
if (function_exists('stream_set_read_buffer')) {
stream_set_read_buffer($this->sock, 0);
}
} else {
stream_set_blocking($this->sock, 1);
}
if ($this->keepalive) {
$this->enable_keepalive();
}
}
开发者ID:Gelembjuk,项目名称:php52-amqplib,代码行数:37,代码来源:StreamIO.php
示例3: onMessage
protected function onMessage($connectionId, $data, $type)
{
//вызывается при получении сообщения от клиента
if (!strlen($data)) {
return;
}
//антифлуд:
$source = explode(':', stream_socket_get_name($this->clients[$connectionId], true));
$ip = $source[0];
$time = time();
if (isset($this->ips[$ip]) && $this->ips[$ip] == $time) {
return;
} else {
$this->ips[$ip] = $time;
}
if ($login = array_search($connectionId, $this->logins)) {
$message = $login . ': ' . strip_tags($data);
$this->sendPacketToMaster('message', $message);
$this->sendPacketToClients('message', $message);
} else {
if (preg_match('/^[a-zA-Z0-9]{1,10}$/', $data, $match)) {
if (isset($this->logins[$match[0]])) {
$this->sendPacketToClient($connectionId, 'message', 'Система: выбранное вами имя занято, попробуйте другое.');
} else {
$this->logins[$match[0]] = -1;
$this->sendPacketToMaster('login', array('login' => $match[0], 'clientId' => $connectionId));
}
} else {
$this->sendPacketToClient($connectionId, 'message', 'Система: ошибка при выборе имени. В имени можно использовать английские буквы и цифры. Имя не должно превышать 10 символов.');
}
}
//var_export($data);
//шлем всем сообщение, о том, что пишет один из клиентов
//echo $data . "\n";
}
开发者ID:JimboOneTwo,项目名称:websocket,代码行数:35,代码来源:Chat2WebsocketWorkerHandler.php
示例4: loop
public function loop()
{
$this->in_loop = true;
while ($this->in_loop) {
$conn = false;
$read = array($this->socket);
$write = null;
$except = null;
declare (ticks=1) {
// stream_socket_accept() doesn't block on some(?) of the ARM systems
// so, wrapping it into stream_select() which works always
// see https://bugs.php.net/bug.php?id=62816
if (1 === @stream_select($read, $write, $except, null)) {
$conn = @stream_socket_accept($this->socket, 0);
}
}
if (false !== $conn) {
$remote_addr = stream_socket_get_name($conn, true);
if (false === $remote_addr) {
$remote_addr = null;
}
call_user_func($this->callback, $conn, $remote_addr);
}
pcntl_signal_dispatch();
}
}
开发者ID:LookForwardPersistence,项目名称:appserver-in-php,代码行数:26,代码来源:Socket.php
示例5: getRemoteAddress
public function getRemoteAddress()
{
if ($this->socket !== false) {
return stream_socket_get_name($this->socket, true);
}
return null;
}
开发者ID:domraider,项目名称:rxnet,代码行数:7,代码来源:Datagram.php
示例6: onAcceptEvent
public function onAcceptEvent($bindSocket, $events, $arg)
{
$bindSocketId = $arg[0];
Debug::netEvent(get_class($this) . '::' . __METHOD__ . '(' . $bindSocketId . ') invoked.');
// add to accept next event
// why not use EV_PERSIST
event_add($this->bindSocketEvPool[$bindSocketId]);
$connSocket = stream_socket_accept($this->bindSocketPool[$bindSocketId]);
if (!$connSocket) {
Debug::netErrorEvent(get_class($this) . ': can not accept new TCP-socket');
return;
}
stream_set_blocking($connSocket, 0);
list($ip, $port) = explode(':', stream_socket_get_name($connSocket, true));
$connId = daemon::getNextConnId();
$evBuf = event_buffer_new($connSocket, array($this, 'onEvBufReadEvent'), array($this, 'onEvBufWriteEvent'), array($this, 'onEventEvent'), array($connId));
event_buffer_base_set($evBuf, daemon::$eventBase);
event_buffer_priority_set($evBuf, 10);
event_buffer_watermark_set($evBuf, EV_READ, $this->evBufLowMark, $this->evBufHighMark);
if (!event_buffer_enable($evBuf, EV_READ | EV_WRITE | EV_PERSIST)) {
Debug::netErrorEvent(get_class($this) . '::' . __METHOD__ . ': can not set base of buffer. #' . $connId);
//close socket
stream_socket_shutdown($connSocket, STREAM_SHUT_RDWR);
fclose($connSocket);
return;
}
// 调试这里时,浪费了很多时间,必须注意的是,以上 event 所用的变量如果在函数中,如果没有交给其他的变量引用,在函数结束时就会销毁,
// 造成连接直接断或者bufferevent 不能触发。晕啊晕。
$this->connSocketPool[$connId] = $connSocket;
$this->connEvBufPool[$connId] = $evBuf;
$this->updateLastContact($connId);
$this->onAccepted($connId, $ip, $port);
}
开发者ID:ansendu,项目名称:ansio,代码行数:33,代码来源:AsyncServer.php
示例7: handshake
function handshake($connect)
{
//Функция рукопожатия
$info = array();
$line = fgets($connect);
$header = explode(' ', $line);
$info['method'] = $header[0];
$info['uri'] = $header[1];
//считываем заголовки из соединения
while ($line = rtrim(fgets($connect))) {
if (preg_match('/\\A(\\S+): (.*)\\z/', $line, $matches)) {
$info[$matches[1]] = $matches[2];
} else {
break;
}
}
$address = explode(':', stream_socket_get_name($connect, true));
//получаем адрес клиента
$info['ip'] = $address[0];
$info['port'] = $address[1];
if (empty($info['Sec-WebSocket-Key'])) {
return false;
}
//отправляем заголовок согласно протоколу вебсокета
$SecWebSocketAccept = base64_encode(pack('H*', sha1($info['Sec-WebSocket-Key'] . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11')));
$upgrade = "HTTP/1.1 101 Web Socket Protocol Handshake\r\n" . "Upgrade: websocket\r\n" . "Connection: Upgrade\r\n" . "Sec-WebSocket-Accept:" . $SecWebSocketAccept . "\r\n\r\n";
fwrite($connect, $upgrade);
return $info;
}
开发者ID:yarkovaleksei,项目名称:WebSocketServer,代码行数:29,代码来源:WebSocketServer.php
示例8: checkConnectedSocket
/** @internal */
public function checkConnectedSocket($socket)
{
// The following hack looks like the only way to
// detect connection refused errors with PHP's stream sockets.
if (false === stream_socket_get_name($socket, true)) {
return Promise\reject(new ConnectionException('Connection refused'));
}
return Promise\resolve($socket);
}
开发者ID:verzulli,项目名称:palestra,代码行数:10,代码来源:TcpConnector.php
示例9: __construct
function __construct($sock, $ssl = false)
{
$this->socket = $sock;
$this->ssl = $ssl;
$ip = stream_socket_get_name($this->socket, true);
$c = strrpos($ip, ":");
$this->ip = substr($ip, 0, $c);
$this->lastping = $this->lastpong = time();
}
开发者ID:slowbro,项目名称:phpircd,代码行数:9,代码来源:user.class.php
示例10: __construct
public function __construct($client)
{
if (!is_resource($client)) {
return;
}
$this->_socket = $client;
$this->name = stream_socket_get_name($client, TRUE);
$this->initialized = TRUE;
}
开发者ID:Jvbzephir,项目名称:zebra_http_server,代码行数:9,代码来源:Request.php
示例11: checkConnectedSocket
public function checkConnectedSocket($socket) : PromiseInterface
{
// The following hack looks like the only way to
// detect connection refused errors with PHP's stream sockets.
if (false === stream_socket_get_name($socket, true)) {
return new RejectedPromise(new ConnectionException('Connection refused'));
}
return new FulfilledPromise($socket);
}
开发者ID:ThrusterIO,项目名称:socket-client,代码行数:9,代码来源:TcpConnector.php
示例12: __construct
public function __construct(EventHttpServer $Server, $Socket)
{
$this->Config = $Server->getConfig();
$this->BaseEvent = $Server->getBaseEvent();
$this->Socket = $Socket;
$this->Name = stream_socket_get_name($Socket, true);
$this->Expire = time() + $this->Config['ClientTransTimeout'];
$this->Server = $Server;
$this->InitSocket();
}
开发者ID:RickySu,项目名称:phpEventHttpd,代码行数:10,代码来源:EventHttpClientSocket.class.php
示例13: __construct
public function __construct(ServerManager $manager, $identifier, $socket)
{
$this->manager = $manager;
$this->identifier = $identifier;
$this->socket = $socket;
$addr = stream_socket_get_name($this->socket, true);
$final = strrpos($addr, ":");
$this->port = (int) substr($addr, $final + 1);
$this->address = substr($addr, 0, $final);
}
开发者ID:iPocketTeam,项目名称:BigBrother,代码行数:10,代码来源:Session.php
示例14: read_requests
function read_requests($client, $options = [])
{
$options['server'] = stream_socket_get_name($client, true);
$dt = CY_Util_Stream::http_read($client, $options);
if ($dt['errno'] !== 0) {
return $dt;
}
if (empty($dt['data'])) {
return array('errno' => CYE_DATA_EMPTY);
}
$o = new http\Message($dt['data']);
$this->version = $o->getHttpVersion();
$this->method = $o->getRequestMethod();
$headers = $o->getHeaders();
if (!empty($headers['Content-Length'])) {
if (isset($headers['Expect'])) {
return array('errno' => CYE_EXPECT_FAIL);
}
if (empty($o->getBody())) {
mp_log(CYE_ERROR, "Bad req:" . $options['server'] . " " . str_replace("\r\n", "\\r\\n", $dt['data']));
}
}
$this->keepalive = isset($headers['Connection']) && strcasecmp($headers['Connection'], 'keep-alive') == 0;
$this->compress = isset($headers['Accept-Encoding']) && strpos($headers['Accept-Encoding'], 'gzip') !== false;
if (empty($headers['Host'])) {
return array('errno' => CYE_ACCESS_DENIED);
}
$parts = parse_url('http://' . $headers['Host'] . $o->getRequestUrl());
$_SERVER['REQUEST_URI'] = $o->getRequestUrl();
$_SERVER['QUERY_STRING'] = '';
if (!empty($parts['query'])) {
$_SERVER['QUERY_STRING'] = $query = $parts['query'];
parse_str($query, $_GET);
}
if (!empty($o->getBody())) {
if (isset($headers['Content-Type']) && strpos($headers['Content-Type'], 'multipart/form-data') !== false) {
// grab multipart boundary from content type header
preg_match('/boundary=(.*)$/', $headers['Content-Type'], $matches);
// content type is probably regular form-encoded
if (count($matches)) {
$boundary = $matches[1];
$_POST = cy_parse_http_multipart($o->getBody(), $boundary);
}
}
if (!isset($boundary)) {
parse_str($o->getBody(), $_POST);
}
}
if (isset($headers['Cookie'])) {
$c = new http\Cookie($headers['Cookie']);
$_COOKIE = $c->getCookies();
}
$_REQUEST = array_merge($_GET, $_POST, $_COOKIE);
return array('errno' => 0);
}
开发者ID:xiaoyjy,项目名称:retry,代码行数:55,代码来源:http.php
示例15: localEndpoint
/**
* Returns local endpoint
*
* @return peer.SocketEndpoint
* @throws peer.SocketException
*/
public function localEndpoint()
{
if (is_resource($this->_sock)) {
if (false === ($addr = stream_socket_get_name($this->_sock, false))) {
throw new SocketException('Cannot get socket name on ' . $this->_sock);
}
return SocketEndpoint::valueOf($addr);
}
return null;
// Not connected
}
开发者ID:johannes85,项目名称:core,代码行数:17,代码来源:Socket.class.php
示例16: onConnected
/**
* @param $socket
* @param ObserverInterface $observer
*/
public function onConnected($socket, $observer)
{
$this->loop->removeWriteStream($socket);
if (false === stream_socket_get_name($socket, true)) {
$observer->onError(new ConnectionException('Connection refused'));
$observer->onCompleted();
return;
}
$observer->onNext(new ConnectorEvent("/connector/connected", new Stream($socket, $this->loop), $this->labels));
//$observer->onCompleted();
}
开发者ID:domraider,项目名称:rxnet,代码行数:15,代码来源:Tcp.php
示例17: onEventAccept
public function onEventAccept($socket, $event)
{
$conn = $this->acceptSocket();
$remote_addr = stream_socket_get_name($conn, true);
if (false === $remote_addr) {
$remote_addr = null;
}
self::log('Socket', 'callback');
call_user_func($this->callback, $conn, $remote_addr);
pcntl_signal_dispatch();
}
开发者ID:LookForwardPersistence,项目名称:appserver-in-php,代码行数:11,代码来源:LibEventUnbuffered.php
示例18: __construct
public function __construct($server, $socket)
{
$this->server = $server;
$this->socket = $socket;
// set some client-information:
$socketName = stream_socket_get_name($socket, true);
$tmp = explode(':', $socketName);
$this->ip = $tmp[0];
$this->port = $tmp[1];
$this->connectionId = md5($this->ip . $this->port . spl_object_hash($this));
$this->log('Connected');
}
开发者ID:kiselyou,项目名称:websocket,代码行数:12,代码来源:Connection.php
示例19: setUp
public function setUp()
{
$host = "127.0.0.1";
$this->serverSocket = stream_socket_server("udp://{$host}:0", $errNo, $errMsg, $flags = STREAM_SERVER_BIND);
if (!$this->serverSocket) {
throw new \RuntimeException("Failed to create test-server-socket");
}
// get random port
$socketName = stream_socket_get_name($this->serverSocket, $peerName = false);
list(, $port) = explode(":", $socketName);
$this->socketClient = new StreamSocketClient('udp', $host, $port);
}
开发者ID:practo,项目名称:gelf-php,代码行数:12,代码来源:StreamSocketClientUdpTest.php
示例20: getPeerName
public function getPeerName(&$ip, &$port)
{
$ip = 'N/A';
$port = -1;
$name = stream_socket_get_name($this->getHandle(), true);
$pos = strpos($name, ':');
if ($pos === false) {
$ip = $name;
} else {
$ip = substr($name, 0, $pos);
$port = substr($name, $pos + 1);
}
}
开发者ID:thefox,项目名称:imapd,代码行数:13,代码来源:StreamSocket.php
注:本文中的stream_socket_get_name函数示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论