首页 / PHP / phpsocket实现的聊天室代码分享_php技巧

phpsocket实现的聊天室代码分享_php技巧

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了phpsocket实现的聊天室代码分享_php技巧，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含10639字，纯文字阅读大概需要16分钟。

内容图文

/**
* patServer
* PHP socket server base class
* Events that can be handled:
*  * onStart
*  * onConnect
*  * onConnectionRefused
*  * onClose
*  * onShutdown
*  * onReceiveData
*
* @version 1.1
* @author  Stephan Schmidt <schst@php-tools.de>
* @package patServer
*/
class patServer {
/**
* information about the project
* @var array $systemVars
*/
var $systemVars  = array(
  "appName"  => "patServer",
  "appVersion"  => "1.1",
  "author"  => array("Stephan Schmidt <schst@php-tools.de>", )
  );

/**
* port to listen
* @var integer  $port
*/
  var $port  = 10000;

/**
* domain to bind to
* @var string $domain
*/
  var $domain  = "localhost";

/**
* maximum amount of clients
* @var integer $maxClients
*/
  var $maxClients = -1;

/**
* buffer size for socket_read
* @var integer $readBufferSize
*/
  var $readBufferSize  = 128;

/**
* end character for socket_read
* @var integer $readEndCharacter
*/
  var $readEndCharacter = "\n";

/**
* maximum of backlog in queue
* @var integer $maxQueue
*/
  var $maxQueue = 500;

/**
* debug mode
* @var boolean $debug
*/
  var $debug  = true;

/**
* debug mode
* @var string $debugMode
*/
  var $debugMode = "text";

/**
* debug destination (filename or stdout)
* @var string $debugDest
*/
  var $debugDest = "stdout";

/**
* empty array, used for socket_select
* @var array $null
*/
  var $null  = array();

/**
* all file descriptors are stored here
* @var array $clientFD
*/
  var $clientFD = array();

/**
* needed to store client information
* @var array $clientInfo
*/
  var $clientInfo = array();

/**
* needed to store server information
* @var array $serverInfo
*/
  var $serverInfo = array();

/**
* amount of clients
* @var integer  $clients
*/
  var $clients = 0;

/**
* create a new socket server
*
* @access public
* @param string  $domain  domain to bind to
* @param integer  $port  port to listen to
*/
function patServer( $domain = "localhost", $port = 10000 )
{
  $this->domain = $domain;
  $this->port  = $port;

  $this->serverInfo["domain"]     = $domain;
  $this->serverInfo["port"]     = $port;
  $this->serverInfo["servername"]   = $this->systemVars["appName"];
  $this->serverInfo["serverversion"] = $this->systemVars["appVersion"];

  set_time_limit( 0 );
}

/**
* set maximum amount of simultaneous connections
*
* @access public
* @param int $maxClients
*/
function setMaxClients( $maxClients )
{
  $this->maxClients = $maxClients;
}

/**
* set debug mode
*
* @access public
* @param mixed $debug [text|htmlfalse]
* @param string $dest destination of debug message (stdout to output or filename if log should be written)
*/
function setDebugMode( $debug, $dest = "stdout" )
{
  if( $debug === false )
  {
  $this->debug = false;
  return true;
  }

  $this->debug  = true;
  $this->debugMode = $debug;
  $this->debugDest = $dest;
}

/**
* start the server
*
* @access public
* @param int $maxClients
*/
function start()
{
  $this->initFD = @socket_create( AF_INET, SOCK_STREAM, 0 );
  if( !$this->initFD )
  die( "patServer: Could not create socket." );

  // adress may be reused
  socket_setopt( $this->initFD, SOL_SOCKET, SO_REUSEADDR, 1 );

  // bind the socket
  if( !@socket_bind( $this->initFD, $this->domain, $this->port ) )
  {
  @socket_close( $this->initFD );
  die( "patServer: Could not bind socket to ".$this->domain." on port ".$this->port." ( ".$this->getLastSocketError( $this->initFd )." )." );
  }

  // listen on selected port
  if( !@socket_listen( $this->initFD, $this->maxQueue ) )
  die( "patServer: Could not listen ( ".$this->getLastSocketError( $this->initFd )." )." );

  $this->sendDebugMessage( "Listening on port ".$this->port.". Server started at ".date( "H:i:s", time() ) );

  // this allows the shutdown function to check whether the server is already shut down
  $GLOBALS["_patServerStatus"] = "running";
  // this ensures that the server will be sutdown correctly
  register_shutdown_function( array( $this, "shutdown" ) );

  if( method_exists( $this, "onStart" ) )
  $this->onStart();

  $this->serverInfo["started"] = time();
  $this->serverInfo["status"]  = "running";

  while( true )
  {
  $readFDs = array();
  array_push( $readFDs, $this->initFD );

  // fetch all clients that are awaiting connections
  for( $i = 0; $i < count( $this->clientFD ); $i++ )
   if( isset( $this->clientFD[$i] ) )
   array_push( $readFDs, $this->clientFD[$i] );

  // block and wait for data or new connection
  $ready = @socket_select( $readFDs, $this->null, $this->null, NULL );

  if( $ready === false )
  {
   $this->sendDebugMessage( "socket_select failed." );
   $this->shutdown();
  }

  // check for new connection
  if( in_array( $this->initFD, $readFDs ) )
  {
   $newClient = $this->acceptConnection( $this->initFD );

   // check for maximum amount of connections
   if( $this->maxClients > 0 )
   {
   if( $this->clients > $this->maxClients )
   {
    $this->sendDebugMessage( "Too many connections." );

    if( method_exists( $this, "onConnectionRefused" ) )
    $this->onConnectionRefused( $newClient );

    $this->closeConnection( $newClient );
   }
   }

   if( --$ready <= 0 )
   continue;
  }

  // check all clients for incoming data
  for( $i = 0; $i < count( $this->clientFD ); $i++ )
  {
   if( !isset( $this->clientFD[$i] ) )
   continue;

   if( in_array( $this->clientFD[$i], $readFDs ) )
   {
   $data = $this->readFromSocket( $i );

   // empty data => connection was closed
   if( !$data )
   {
    $this->sendDebugMessage( "Connection closed by peer" );
    $this->closeConnection( $i );
   }
   else
   {
    $this->sendDebugMessage( "Received ".trim( $data )." from ".$i );

    if( method_exists( $this, "onReceiveData" ) )
    $this->onReceiveData( $i, $data );
   }
   }
  }
  }
}

/**
* read from a socket
*
* @access private
* @param integer $clientId internal id of the client to read from
* @return string $data  data that was read
*/
function readFromSocket( $clientId )
{
  // start with empty string
  $data  = "";

  // read data from socket
  while( $buf = socket_read( $this->clientFD[$clientId], $this->readBufferSize ) )
  {
  $data .= $buf;

  $endString = substr( $buf, - strlen( $this->readEndCharacter ) );
  if( $endString == $this->readEndCharacter )
   break;
  if( $buf == NULL )
   break;
  }

  if( $buf === false )
  $this->sendDebugMessage( "Could not read from client ".$clientId." ( ".$this->getLastSocketError( $this->clientFD[$clientId] )." )." );

  return $data;
}

/**
* accept a new connection
*
* @access public
* @param resource &$socket socket that received the new connection
* @return int  $clientID internal ID of the client
*/
function acceptConnection( &$socket )
{
  for( $i = 0 ; $i <= count( $this->clientFD ); $i++ )
  {
  if( !isset( $this->clientFD[$i] ) || $this->clientFD[$i] == NULL )
  {
   $this->clientFD[$i] = socket_accept( $socket );
   socket_setopt( $this->clientFD[$i], SOL_SOCKET, SO_REUSEADDR, 1 );
   $peer_host = "";
   $peer_port = "";
   socket_getpeername( $this->clientFD[$i], $peer_host, $peer_port );
   $this->clientInfo[$i] = array(
       "host"  => $peer_host,
       "port"  => $peer_port,
       "connectOn" => time()
       );
   $this->clients++;

   $this->sendDebugMessage( "New connection ( ".$i." ) from ".$peer_host." on port ".$peer_port );

   if( method_exists( $this, "onConnect" ) )
   $this->onConnect( $i );
   return $i;
  }
  }
}

/**
* check, whether a client is still connected
*
* @access public
* @param integer $id client id
* @return boolean $connected true if client is connected, false otherwise
*/
function isConnected( $id )
{
  if( !isset( $this->clientFD[$id] ) )
  return false;
  return true;
}

/**
* close connection to a client
*
* @access public
* @param int $clientID internal ID of the client
*/
function closeConnection( $id )
{
  if( !isset( $this->clientFD[$id] ) )
  return false;

  if( method_exists( $this, "onClose" ) )
  $this->onClose( $id );

  $this->sendDebugMessage( "Closed connection ( ".$id." ) from ".$this->clientInfo[$id]["host"]." on port ".$this->clientInfo[$id]["port"] );

  @socket_close( $this->clientFD[$id] );
  $this->clientFD[$id] = NULL;
  unset( $this->clientInfo[$id] );
  $this->clients--;
}

/**
* shutdown server
*
* @access public
*/
function shutDown()
{
  if( $GLOBALS["_patServerStatus"] != "running" )
  exit;
  $GLOBALS["_patServerStatus"] = "stopped";

  if( method_exists( $this, "onShutdown" ) )
  $this->onShutdown();

  $maxFD = count( $this->clientFD );
  for( $i = 0; $i < $maxFD; $i++ )
  $this->closeConnection( $i );

  @socket_close( $this->initFD );

  $this->sendDebugMessage( "Shutdown server." );
  exit;
}

/**
* get current amount of clients
*
* @access public
* @return int $clients amount of clients
*/
function getClients()
{
  return $this->clients;
}

/**
* send data to a client
*
* @access public
* @param int  $clientId ID of the client
* @param string $data  data to send
* @param boolean $debugData flag to indicate whether data that is written to socket should also be sent as debug message
*/
function sendData( $clientId, $data, $debugData = true )
{
  if( !isset( $this->clientFD[$clientId] ) || $this->clientFD[$clientId] == NULL )
  return false;

  if( $debugData )
  $this->sendDebugMessage( "sending: \"" . $data . "\" to: $clientId" );

  if( !@socket_write( $this->clientFD[$clientId], $data ) )
  $this->sendDebugMessage( "Could not write '".$data."' client ".$clientId." ( ".$this->getLastSocketError( $this->clientFD[$clientId] )." )." );
}

/**
* send data to all clients
*
* @access public
* @param string $data  data to send
* @param array $exclude client ids to exclude
*/
function broadcastData( $data, $exclude = array(), $debugData = true )
{
  if( !empty( $exclude ) && !is_array( $exclude ) )
  $exclude = array( $exclude );

  for( $i = 0; $i < count( $this->clientFD ); $i++ )
  {
  if( isset( $this->clientFD[$i] ) && $this->clientFD[$i] != NULL && !in_array( $i, $exclude ) )
  {
   if( $debugData )
   $this->sendDebugMessage( "sending: \"" . $data . "\" to: $i" );

   if( !@socket_write( $this->clientFD[$i], $data ) )
   $this->sendDebugMessage( "Could not write '".$data."' client ".$i." ( ".$this->getLastSocketError( $this->clientFD[$i] )." )." );
  }
  }
}

/**
* get current information about a client
*
* @access public
* @param int  $clientId ID of the client
* @return array $info  information about the client
*/
function getClientInfo( $clientId )
{
  if( !isset( $this->clientFD[$clientId] ) || $this->clientFD[$clientId] == NULL )
  return false;
  return $this->clientInfo[$clientId];
}

/**
* send a debug message
*
* @access private
* @param string $msg message to debug
*/
function sendDebugMessage( $msg )
{
  if( !$this->debug )
  return false;

  $msg = date( "Y-m-d H:i:s", time() ) . " " . $msg;

  switch( $this->debugMode )
  {
  case "text":
   $msg = $msg."\n";
   break;
  case "html":
   $msg = htmlspecialchars( $msg ) . "
\n";
   break;
  }

  if( $this->debugDest == "stdout" || empty( $this->debugDest ) )
  {
  echo $msg;
  flush();
  return true;
  }

  error_log( $msg, 3, $this->debugDest );
  return true;
}

/**
* return string for last socket error
*
* @access public
* @return string $error last error
*/
function getLastSocketError( &$fd )
{
  $lastError = socket_last_error( $fd );
  return "msg: " . socket_strerror( $lastError ) . " / Code: ".$lastError;
}
function onReceiveData($ip,$data){

  $this->broadcastData( $data,array(), true );
}
}


$patServer = new patServer();
$patServer->start();

内容总结

以上是互联网集市为您收集整理的phpsocket实现的聊天室代码分享_php技巧全部内容，希望文章能够帮你解决phpsocket实现的聊天室代码分享_php技巧所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/262718.html

来源：【匿名】

【上一篇】PHP+FastCGI+Nginx配置PHP运行环境_php实例【下一篇】PHP 5 数据对象 (PDO) 抽象层与 Oracle

更多 ►

【phpsocket实现的聊天室代码分享_php技巧】教程文章相关的互联网学习教程文章

5种PHP创建数组的实例代码分享

看这篇文章之前相信大家都已经看过PHP中文手册关于数组这一节的讲解了，怎么样呢，看懂了多少？至少我第一次阅读文档时是一头雾水，也许是因为在翻译的不够通俗易懂吧^_^！！这里UncleToo根据自己的经验，将数组的各种创建方式用PHP实例代码的方式分享给大家，希望对大家有些帮助（当然，PHP文档还是要多看的） 1、使用array()创建数组 array()创建数组是我们在PHP开发过程中最常用到的一种方式，准确来说array()是一种结构而不是一...

PHP文件操作实现代码分享【图】

将数据写或读入文件，基本上分为三个步骤： 1. 打开一个文件（如果存在） 2. 写/读文件 3. 关闭这个文件 l打开文件在打开文件文件之前，我们需要知道这个文件的路径，以及此文件是否存在。用$_SERVER[“DOCUMENT_ROOT”]内置全局变量，来获得站点的相对路径。如下： $root = $_SERVER[“DOCUMENT_ROOT”]; 在用函数file_exists()来检测文件是否存在。如下： If(!file_exists("$root/order.txt")){echo ‘文件不存在‘;} 接下来用...

ThinkPHP文件缓存类代码分享【代码】

取自ThinkPHP的文件缓存类代码，这里就不多废话了，小伙伴们自己看注释吧。 <?php/*** @desc 文件缓存*/class Cache{const C_FILE = ‘/Runtime/‘;private $dir = ‘‘;const EXT = ‘.tpl‘;private $filename = ‘‘;public function __construct($dir = ‘‘){$this->dir = $dir;}/*** @desc 设置文件缓存* @param string $key 文件名 * @param unkonw $data 缓存数据* @param int $expire 过期时间*/public function set...

THINKPHP内容分页代码分享

在使用Thinkphp开发的内容管理系统里面，很多东西都要自己开发，内容分页当然也是要自己开发的，下面是我根据查资料自己整理的方法:1、首先是在后台编辑内容的时候需要插入分页符，不同的编辑器分页符自然也不同了2、然后就是读取文章内容的时候，要根据分页符来把内容分割成多个数组然，这里需要传值当前是第几页，根据页数来读取分割后的数组代码如下：复制代码代码如下: <php> $arr_con=explode(‘_ueditor_page_break_tag...

PHP版QQ互联OAuth示例代码分享

/** * QQ互联 oauth * @author dyllen * @edit http://www.lai18.com * @date 2015-07-06 */class Oauth{ //取Authorization Code Url const PC_CODE_URL = ‘https://graph.qq.com/oauth2.0/authorize‘; //取Access Token Url const PC_ACCESS_TOKEN_URL = ‘https://graph.qq.com/oauth2.0/token‘; //取用户 Open Id Url const OPEN_ID_URL = ‘https://graph.qq.com/oauth2.0/me‘; //用户授权之后的回调地...

一个php网站缓存代码分享

/** * @author Seraphim * @copyright 2012 * @link http://bbs.it-home.org*/ // function sendheader($last_modified, $p_type, $content_length = 0) { // 设置客户端缓存有效时间 header("Expires: " . gmdate("D, d M Y H:i:s", time() + 15360000) . "GMT"); header("Cache-Control: max-age=315360000"); header("Pragma: "); // 设置最后修改时间 header("Last-Modified: " . $last_modified); // 设置文件类型信息 heade...

php文件缓存数据类的代码分享

本文分享一个php文件缓存数据类，写的挺规范挺好的，后面有调用示例。有需要的朋友参考下。说到php文件缓存，回顾之前介绍的文章，找到了这么几篇： php 缓存类调用示例 PHP 数据缓存的实例代码 php 页面缓存类，大家可以参考下。有了以上对于php 文件缓存的基础，下面开始今天的内容。代码如下：cachePath = $path; } } /** * 析构函数 */ function __destruct() { //nothing } /** * 在cache中设置键为$key的项的值，如...

ThinkPHP文件缓存类代码分享_PHP

取自ThinkPHP的文件缓存类代码，这里就不多废话了，小伙伴们自己看注释吧。<?php/*** @desc 文件缓存*/class Cache{const C_FILE = /Runtime/;private $dir = ;const EXT = .tpl;private $filename = ;public function __construct($dir = ){$this->dir = $dir;}/*** @desc 设置文件缓存* @param string $key 文件名 * @param unkonw $data 缓存数据* @param int $expire 过期时间*/public function set($key,$data,$expire =...

ThinkPHP文件缓存类代码分享_php实例

取自ThinkPHP的文件缓存类代码，这里就不多废话了，小伙伴们自己看注释吧。 <?php/*** @desc 文件缓存*/class Cache{const C_FILE = /Runtime/;private $dir = ;const EXT = .tpl;private $filename = ;public function __construct($dir = ){$this->dir = $dir;}/*** @desc 设置文件缓存* @param string $key 文件名 * @param unkonw $data 缓存数据* @param int $expire 过期时间*/public function set($key,$data,$expire ...

ThinkPHP文件缓存类代码分享，_PHP教程

ThinkPHP文件缓存类代码分享，取自ThinkPHP的文件缓存类代码，这里就不多废话了，小伙伴们自己看注释吧。 <?php/*** @desc 文件缓存*/class Cache{const C_FILE = /Runtime/;private $dir = ;const EXT = .tpl;private $filename = ;public function __construct($dir = ){$this->dir = $dir;}/*** @desc 设置文件缓存* @param string $key 文件名 * @param unkonw $data 缓存数据* @param int $expire 过期时间*/public func...

ThinkPHP文件缓存类代码分享_PHP教程

ThinkPHP文件缓存类代码分享　　ThinkPHP文件缓存类代码分享取自ThinkPHP的文件缓存类代码，这里就不多废话了，小伙伴们自己看注释吧。? 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364<?php/*** @desc 文件缓存*/class Cache{const C_FILE = /Runtime/;private $dir = ;const EXT = .tpl;private $filename = ;public function __construct($dir = ...

ThinkPHP文件缓存类代码分享

取自ThinkPHP的文件缓存类代码，这里就不多废话了，小伙伴们自己看注释吧。 <?php/*** @desc 文件缓存*/class Cache{const C_FILE = /Runtime/;private $dir = ;const EXT = .tpl;private $filename = ;public function __construct($dir = ){$this->dir = $dir;}/*** @desc 设置文件缓存* @param string $key 文件名 * @param unkonw $data 缓存数据* @param int $expire 过期时间*/public function set($key,$data,$expire ...

php的缓存机制实现页面静态化代码分享

本文主要为大家带来一篇利用php的ob缓存机制实现页面静态化方法。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧，希望能帮助到大家。首先介绍一下php中ob缓存常用到的几个常用函数ob_start（）：开启缓存机制ob_get_contents（）：获取ob缓存中的内容ob_clean（）清除ob缓存中的内容，但不关闭缓存ob_end_clean() 清除ob缓存中的内容，并关闭缓存ob_flush 清空缓存，输出内容，但不关闭缓存ob_en...

Php图像处理类代码分享

目前只实现了三个功能：1：图片缩放，2：图片裁剪，3：加图片水印在实例化中，通过给第二个参数传不同的值，从而实现不同的功能代码如下:include "image.class.php"; $image=new image("2.png", 1, "300", "500", "5.png"); //使用图片缩放功能 $image=new image("2.png", 2, "0,0", "50,50", "5.png"); //使用图片裁剪功能 $image=new image("2.png", 3, "1.png", "0", "5.png"); //使用加图片水印功能 $image->outimage(); ?>...

Php图像处理类代码分享_php技巧

PHP - 技术教程分类

PHP 教程 PHP 简介 PHP 安装 PHP 语法 PHP 变量 PHP echo/print PHP EOF(heredoc) PHP 数据类型 PHP 类型比较 PHP 常量 PHP 字符串 PHP 运算符 PHP If...Else PHP Switch PHP 数组 PHP 数组排序 PHP 超级全局变量 PHP While 循环 PHP For 循环 PHP 函数 PHP 魔术常量 PHP 命名空间 PHP 面向对象 PHP 测验 PHP 表单 PHP 表单验证 PHP 表单 - 必需字段 PHP 完整表单实例 PHP $_GET 变量 PHP $_POST 变量 PHP 多维数组 PHP 日期 PHP 包含 PHP 文件 PHP 文件上传 PHP Cookie PHP Session PHP E-mail PHP Error PHP Exception PHP 过滤器 PHP 7 新特性 PHP MySQL 简介 PHP MySQL 连接 PHP MySQL 创建数据库 PHP MySQL 创建数据表 PHP MySQL 插入数据 PHP MySQL 插入多条数据 PHP MySQL 预处理语句 PHP MySQL 读取数据 PHP MySQL Where PHP MySQL Order By PHP MySQL Update PHP MySQL Delete PHP ODBC AJAX 简介 AJAX PHP AJAX 数据库 AJAX 实时搜索 AJAX 投票 PHP Array PHP Calendar PHP cURL PHP Date PHP Directory PHP Error PHP Filesystem PHP Filter PHP FTP PHP HTTP PHP Mail PHP Math PHP Misc PHP MySQLi PHP PDO PHP String PHP Zip PHP Timezones PHP 图像处理 PHP RESTful PHP PCRE PHP 可用的函数 PHP Composer php 全部

PHP - 最热教程

php如何取出数组的前几个元素 PHP变量什么时候释放 PHP如何实现在数据库随机获取几条记录如何解决php base64解码乱码 php主要用于哪些领域 Laravel 批量插入(insert)数据六款国内优秀免费wordpress主题推荐 React如何从后端获取数据并渲染到前端？纯PHP实现定时器任务（Timer），php实现...php该如何安装pdo_mysql扩展

首页 / PHP / phpsocket实现的聊天室代码分享_php技巧

phpsocket实现的聊天室代码分享_php技巧

内容导读

内容图文

内容总结

内容备注

内容手机端

【phpsocket实现的聊天室代码分享_php技巧】教程文章相关的互联网学习教程文章

5种PHP创建数组的实例代码分享

PHP文件操作实现代码分享【图】

ThinkPHP文件缓存类代码分享【代码】

THINKPHP内容分页代码分享

PHP版QQ互联OAuth示例代码分享

一个php网站缓存代码分享

php文件缓存数据类的代码分享

ThinkPHP文件缓存类代码分享_PHP

ThinkPHP文件缓存类代码分享_php实例

ThinkPHP文件缓存类代码分享，_PHP教程

ThinkPHP文件缓存类代码分享_PHP教程

ThinkPHP文件缓存类代码分享

php的缓存机制实现页面静态化代码分享

Php图像处理类代码分享

Php图像处理类代码分享_php技巧

PHPS - 相关标签

PHP - 技术教程分类

PHP - 最新教程

PHP - 最热教程