PHP TSocket类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› PHP›PHP编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了PHP中TSocket类的典型用法代码示例。如果您正苦于以下问题：PHP TSocket类的具体用法？PHP TSocket怎么用？PHP TSocket使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

在下文中一共展示了TSocket类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的PHP代码示例。

示例1: __construct

 public function __construct($keyspace, $server, $credentials, $framed_transport, $send_timeout, $recv_timeout)
 {
     $host = $server['host'];
     $port = $server['port'];
     $socket = new TSocket($host, $port);
     if ($send_timeout) {
         $socket->setSendTimeout($send_timeout);
     }
     if ($recv_timeout) {
         $socket->setRecvTimeout($recv_timeout);
     }
     if ($framed_transport) {
         $transport = new TFramedTransport($socket, true, true);
     } else {
         $transport = new TBufferedTransport($socket, 1024, 1024);
     }
     $client = new CassandraClient(new TBinaryProtocolAccelerated($transport));
     $transport->open();
     # TODO check API major version match
     $server_version = explode(".", $client->describe_version());
     $server_version = $server_version[0];
     if ($server_version < self::LOWEST_COMPATIBLE_VERSION) {
         $ver = self::LOWEST_COMPATIBLE_VERSION;
         throw new IncompatbleAPIException("The server's API version is too " . "low to be comptible with phpcassa (server: {$server_version}, " . "lowest compatible version: {$ver})");
     }
     $client->set_keyspace($keyspace);
     if ($credentials) {
         $request = cassandra_AuthenticationRequest($credentials);
         $client->login($request);
     }
     $this->keyspace = $keyspace;
     $this->client = $client;
     $this->transport = $transport;
 }

开发者ID:htmlgraphic，项目名称:HTMLgraphic-MVC，代码行数:34，代码来源:connection.php

示例2: __construct

 public function __construct($keyspace, $server, $credentials = null, $framed_transport = True, $send_timeout = null, $recv_timeout = null)
 {
     $this->server = $server;
     $server = explode(':', $server);
     $host = $server[0];
     if (count($server) == 2) {
         $port = (int) $server[1];
     } else {
         $port = self::DEFAULT_PORT;
     }
     $socket = new \TSocket($host, $port);
     if ($send_timeout) {
         $socket->setSendTimeout($send_timeout);
     }
     if ($recv_timeout) {
         $socket->setRecvTimeout($recv_timeout);
     }
     if ($framed_transport) {
         $transport = new \TFramedTransport($socket, true, true);
     } else {
         $transport = new \TBufferedTransport($socket, 1024, 1024);
     }
     $this->client = new CassandraClient(new \TBinaryProtocolAccelerated($transport));
     $transport->open();
     $this->set_keyspace($keyspace);
     if ($credentials) {
         $request = new AuthenticationRequest(array("credentials" => $credentials));
         $this->client->login($request);
     }
     $this->keyspace = $keyspace;
     $this->transport = $transport;
     $this->op_count = 0;
 }

开发者ID:codewinguagua，项目名称:Cassandra-Cluster-Admin，代码行数:33，代码来源:ConnectionWrapper.php

示例3: __get

 public function __get($name)
 {
     if (isset($this->services[$name])) {
         if (is_string($this->services[$name])) {
             if (isset($this->service_config[$name])) {
                 $config = $this->service_config[$name];
                 if (empty($config['send_timeout'])) {
                     $config['send_timeout'] = $this->send_timeout;
                 }
                 if (empty($config['recv_timeout'])) {
                     $config['recv_timeout'] = $this->recv_timeout;
                 }
                 $transport = new TSocket($config['server_host'], $config['server_port']);
                 $transport->setSendTimeout($config['send_timeout'] * 1000);
                 $transport->setRecvTimeout($config['recv_timeout'] * 1000);
                 $transport->open();
                 $protocol = new TBinaryProtocol(new TBufferedTransport($transport));
                 $class = $this->services[$name];
                 $this->services[$name] = new $class($protocol);
             } else {
                 $transport = new TSocket($this->server_host, $this->server_port);
                 $transport->setSendTimeout($this->send_timeout * 1000);
                 $transport->setRecvTimeout($this->recv_timeout * 1000);
                 $transport->open();
                 $protocol = new TBinaryProtocol(new TBufferedTransport($transport));
                 $class = $this->services[$name];
                 $this->services[$name] = new $class($protocol);
             }
         }
         return $this->services[$name];
     } else {
         throw new Exception('Service Not Defined');
     }
 }

开发者ID:wheatma，项目名称:react_study，代码行数:34，代码来源:ThriftClient.php

示例4: __construct

 public function __construct($keyspace, $server, $credentials, $framed_transport, $send_timeout, $recv_timeout)
 {
     $host = $server['host'];
     $port = $server['port'];
     $socket = new TSocket($host, $port);
     if ($send_timeout) {
         $socket->setSendTimeout($send_timeout);
     }
     if ($recv_timeout) {
         $socket->setRecvTimeout($recv_timeout);
     }
     if ($framed_transport) {
         $transport = new TFramedTransport($socket, true, true);
     } else {
         $transport = new TBufferedTransport($socket, 1024, 1024);
     }
     $client = new CassandraClient(new TBinaryProtocolAccelerated($transport));
     $transport->open();
     # TODO check API major version match
     $client->set_keyspace($keyspace);
     if ($credentials) {
         $request = cassandra_AuthenticationRequest($credentials);
         $client->login($request);
     }
     $this->keyspace = $keyspace;
     $this->client = $client;
     $this->transport = $transport;
 }

开发者ID:karlhiramoto，项目名称:phpcassa，代码行数:28，代码来源:connection.php

示例5: getAiravataClient

    public function getAiravataClient()
    {
        $transport = new TSocket($this->airavataServerHost, $this->airavataServerPort);
        $protocol = new TBinaryProtocol($transport);
	$transport->open();
        return new AiravataClient($protocol);
    }

开发者ID:sanyaade-iot，项目名称:airavata-php-gateway，代码行数:7，代码来源:AiravataClientFactory.php

示例6: add_node

 public static function add_node($host, $port = self::DEFAULT_THRIFT_PORT, $framed_transport = false, $send_timeout = null, $recv_timeout = null, $persist = false)
 {
     try {
         // Create Thrift transport and binary protocol cassandra client
         $socket = new TSocket($host, $port, $persist);
         if ($send_timeout) {
             $socket->setSendTimeout($send_timeout);
         }
         if ($recv_timeout) {
             $socket->setRecvTimeout($recv_timeout);
         }
         if ($framed_transport) {
             $transport = new TFramedTransport($socket, true, true);
         } else {
             $transport = new TBufferedTransport($socket, 1024, 1024);
         }
         $client = new CassandraClient(new TBinaryProtocolAccelerated($transport));
         // Store it in the connections
         self::$connections[] = array('transport' => $transport, 'client' => $client);
         // Done
         return TRUE;
     } catch (TException $tx) {
         self::$last_error = 'TException: ' . $tx->getMessage() . "\n";
     }
     return FALSE;
 }

开发者ID:hoan，项目名称:phpcassa，代码行数:26，代码来源:phpcassa.php

示例7: getConnector

 /**
  * Create connector object
  * @param array $config
  * @return TTransport
  */
 private static function getConnector($config)
 {
     $class = isset($config['class']) ? $config['class'] : '';
     $param = isset($config['param']) ? $config['param'] : array();
     switch ($class) {
         case 'THttpClient':
             if (!isset($param['host'])) {
                 throw new Exception('Bad Thrift transport config');
             }
             $host = $param['host'];
             $port = isset($param['port']) ? $param['port'] : 80;
             $uri = isset($param['uri']) ? $param['uri'] : '';
             $scheme = isset($param['scheme']) ? $param['scheme'] : 'http';
             $timeout = isset($param['timeout']) ? $param['timeout'] : null;
             $connector = new THttpClient($url, $port, $uri, $scheme);
             $connector->setTimeoutSecs($timeout);
             $parameters = sprintf('host = "%s", port = %d, uri = "%s", scheme = "%s", timeout = %d', $host, $port, $uri, $scheme, $timeout);
             break;
         case 'TMemoryBuffer':
             $buf = isset($param['buf']) ? $param['buf'] : '';
             $connector = new TMemoryBuffer($buf);
             $parameters = sprintf('buf = "%s"', $buf);
             break;
         case 'TPhpStream':
             if (!isset($param['mode'])) {
                 throw new Exception('Bad Thrift transport config');
             }
             $mode = $param['mode'];
             $connector = new TPhpStream($mode);
             $parameters = sprintf('mode = %d', $mode);
             break;
         case 'TSocket':
             $host = isset($param['host']) ? $param['host'] : 'localhost';
             $port = isset($param['port']) ? $param['port'] : 9090;
             $persist = isset($param['persist']) ? $param['persist'] : false;
             $send_timeout = isset($param['send_timeout']) ? $param['send_timeout'] : 100;
             $recv_timeout = isset($param['recv_timeout']) ? $param['recv_timeout'] : 750;
             $connector = new TSocket($host, $port, $persist);
             $connector->setSendTimeout($send_timeout);
             $connector->setRecvTimeout($recv_timeout);
             $parameters = sprintf('host = "%s", port = %d, persist = %s, send_timeout = %d, recv_timeout = %d', $host, $port, $persist ? 'true' : 'false', $send_timeout, $recv_timeout);
             break;
         case 'TSocketPool':
             $hosts = isset($param['hosts']) ? $param['hosts'] : array('localhost');
             $ports = isset($param['ports']) ? $param['ports'] : array(9090);
             $persist = isset($param['persist']) ? $param['persist'] : false;
             $send_timeout = isset($param['send_timeout']) ? $param['send_timeout'] : 100;
             $recv_timeout = isset($param['recv_timeout']) ? $param['recv_timeout'] : 750;
             $connector = new TSocketPool($hosts, $ports, $persist);
             $connector->setSendTimeout($send_timeout);
             $connector->setRecvTimeout($recv_timeout);
             $parameters = sprintf('hosts = ("%s"), ports = (%d), persist = %s, send_timeout = %d, recv_timeout = %d', implode('","', $hosts), implode('","', $ports), $persist ? 'true' : 'false', $send_timeout, $recv_timeout);
             break;
         default:
             throw new Exception('Unknown connector: ' . $class);
     }
     sfContext::getInstance()->getLogger()->info(sprintf('{sfThriftPlugin}Create %s connector with parameters: %s', $class, $parameters));
     return $connector;
 }

开发者ID:tomi77，项目名称:sfThriftPlugin，代码行数:64，代码来源:ThriftProtocolFactory.class.php

示例8: initialize

 public function initialize($param)
 {
     $this->host = $param['host'];
     $this->port = $param['port'];
     $socket = new \TSocket($this->host, $this->port);
     $socket->setSendTimeout(2000);
     $socket->setRecvTimeout(5000);
     $transport = new \TBufferedTransport($socket, 512, 512);
     $protocol = new \TBinaryProtocol($transport);
     $this->hbaseThriftClient = new \THBaseServiceClient($protocol);
     $transport->open();
 }

开发者ID:nedvisol，项目名称:phporm，代码行数:12，代码来源:HbaseClient.php

示例9: __construct

 function __construct($host, $port, $timeout_ms = 300000, $do_open = true)
 {
     $socket = new TSocket($host, $port);
     $socket->setSendTimeout($timeout_ms);
     $socket->setRecvTimeout($timeout_ms);
     $this->transport = new TFramedTransport($socket);
     $protocol = new TBinaryProtocol($this->transport);
     parent::__construct($protocol);
     if ($do_open) {
         $this->open();
     }
 }

开发者ID:kamoljan，项目名称:hypertable，代码行数:12，代码来源:ThriftClient.php

示例10: __construct

 function __construct($options)
 {
     $config = Zend_Registry::get('configuration');
     $this->socket = new TSocket($config->stdprofile->host, $config->stdprofile->port);
     $this->socket->setSendTimeout($this->sendTimeout);
     $this->socket->setRecvTimeout($this->recvTimeout);
     $this->transport = new TFramedTransport($this->socket);
     $this->protocol = new TBinaryProtocolAccelerated($this->transport);
     $this->client = new StdProfile2Service_RdClient($this->protocol);
     $this->_handle = new zcommon_OpHandle();
     $this->_handle->source = $config->stdprofile->source;
     $this->_handle->auth = $config->stdprofile->auth;
 }

开发者ID:utcuong3010，项目名称:vng，代码行数:13，代码来源:stdprofile.php

示例11: connect

 public static function connect($params = array())
 {
     self::$config = $params;
     // Initialize Thrift connection
     $socket = new \TSocket($params["server"], 9090);
     $socket->setSendTimeout(3000);
     $socket->setRecvTimeout(10000);
     $transport = new \TBufferedTransport($socket);
     $protocol = new \TBinaryProtocol($transport);
     $client = new \HbaseClient($protocol);
     $transport->open();
     self::$hbase = new ThriftHBaseClientWrapper($client);
 }

开发者ID:terry80504，项目名称:MySQL-HBase-SQLBridge，代码行数:13，代码来源:mmb.php

示例12: __construct

 private function __construct()
 {
     try {
         $socket = new TSocket('localhost', '9030');
         $socket->setRecvTimeout(50000);
         $this->transport = new TBufferedTransport($socket);
         $protocol = new TBinaryProtocol($this->transport);
         $this->client = new TedServiceClient($protocol);
         $this->transport->open();
     } catch (TException $tx) {
         // a general thrift exception, like no such server
         echo "ThriftException: " . $tx->getMessage() . "\r\n";
     }
 }

开发者ID:ted，项目名称:ted，代码行数:14，代码来源:client_support.php

示例13: connect

 private function connect()
 {
     try {
         $options = array('host' => '10.30.22.135', 'port' => 7114);
         $socket = new TSocket($options['host'], $options['port']);
         $socket->setSendTimeout(10000);
         $socket->setRecvTimeout(10000);
         $this->transport = new TFramedTransport($socket);
         $protocol = new TBinaryProtocol($this->transport);
         $this->client = new TTokenClient($protocol);
     } catch (Exception $e) {
         throw $e;
     }
 }

开发者ID:utcuong3010，项目名称:vng，代码行数:14，代码来源:TokenGenerator.php

示例14: __construct

 /**
  * Constructor.  Initialize the model object
  *
  * @param array $conf   The global config information
  */
 function __construct($conf)
 {
     $this->sql_database = null;
     $this->hive_database = null;
     if ($conf['database_type'] == 'mysql') {
         $this->sql_database = new medoo(array('database_type' => 'mysql', 'database_name' => $conf['default_schema'], 'server' => $conf['host'], 'port' => $conf['port'], 'username' => $conf['user'], 'password' => $conf['password']));
     }
     if ($conf['database_type'] == 'hive') {
         $transport = new TSocket($conf['host'], $conf['port']);
         $transport->setSendTimeout(600 * 1000);
         $transport->setRecvTimeout(600 * 1000);
         $this->hive_database = new ThriftHiveClientEx(new TBinaryProtocol($transport));
     }
 }

开发者ID:Adapp，项目名称:propagator，代码行数:19，代码来源:DatabaseWrapper.php

示例15: connect

 private function connect()
 {
     try {
         $config = $this->getConfig();
         $options = array('host' => $config->thrift->host, 'port' => $config->thrift->port);
         $socket = new TSocket($options['host'], $options['port']);
         $socket->setSendTimeout($config->thrift->timeout->send);
         $socket->setRecvTimeout($config->thrift->timeout->recv);
         $this->transport = new TFramedTransport($socket);
         $protocol = new TBinaryProtocol($this->transport);
         $this->client = new T_PaymentBOClient($protocol);
     } catch (Exception $e) {
         throw $e;
     }
 }

开发者ID:utcuong3010，项目名称:vng，代码行数:15，代码来源:MAC.php

示例16: accept

 public function accept($timeout = -1)
 {
     if ($timeout !== 0) {
         $client = stream_socket_accept($this->handle, $timeout);
     } else {
         $client = stream_socket_accept($this->handle, $timeout);
     }
     if (!\hacklib_cast_as_boolean($client)) {
         return null;
     }
     $socket = new TSocket();
     $socket->setHandle($client);
     $transport = new TBufferedTransport($socket, $this->send_buffer_size, $this->recv_buffer_size);
     return $transport;
 }

开发者ID:davidnasar，项目名称:fbthrift，代码行数:15，代码来源:TServerSocket.php

示例17: connect

 private function connect()
 {
     try {
         $config = Zend_Registry::get('appconf');
         $options = array('host' => $config->billing->host, 'port' => $config->billing->port);
         $socket = new TSocket($options['host'], $options['port']);
         $socket->setSendTimeout($config->billing->connection->sendtimeout);
         $socket->setRecvTimeout($config->billing->connection->recvtimeout);
         $this->transport = new TFramedTransport($socket);
         $protocol = new TBinaryProtocol($this->transport);
         $this->client = new TPaymentClient($protocol);
     } catch (Exception $e) {
         throw $e;
     }
 }

开发者ID:utcuong3010，项目名称:vng，代码行数:15，代码来源:Billing.php

示例18: connect

 private function connect()
 {
     try {
         $config = Zend_Registry::get('appconf');
         $options = array('host' => $config->token->host, 'port' => $config->token->port);
         /* $options = array('host'=>'10.199.18.36',
            'port'=>7114);*/
         $socket = new TSocket($options['host'], $options['port']);
         $socket->setSendTimeout($config->token->connection->sendtimeout);
         $socket->setRecvTimeout($config->token->connection->sendtimeout);
         $this->transport = new TFramedTransport($socket);
         $protocol = new TBinaryProtocol($this->transport);
         $this->client = new TTokenClient($protocol);
     } catch (Exception $e) {
         throw $e;
     }
 }

开发者ID:utcuong3010，项目名称:vng，代码行数:17，代码来源:TokenGenerator.php

示例19: connect

 private function connect()
 {
     try {
         //            $config = $this->getConfig();
         //            $options = array('host'=>$config->thrift->host,
         //                             'port'=>$config->thrift->port);
         $options = array('host' => '10.30.22.135', 'port' => 6161);
         $socket = new TSocket($options['host'], $options['port']);
         $socket->setSendTimeout(1000);
         $socket->setRecvTimeout(1000);
         $this->transport = new TFramedTransport($socket);
         $protocol = new TBinaryProtocol($this->transport);
         $this->client = new TPaymentClient($protocol);
     } catch (Exception $e) {
         throw $e;
     }
 }

开发者ID:utcuong3010，项目名称:vng，代码行数:17，代码来源:Billing.php

示例20: accept

 public function accept($timeout = -1)
 {
     if ($timeout !== 0) {
         $client = stream_socket_accept($this->handle, $timeout);
     } else {
         $client = @stream_socket_accept($this->handle, $timeout);
     }
     if (!$client) {
         return false;
     }
     $socket = new TSocket();
     $socket->setHandle($client);
     // We need to create a buffered transport because TSocket's isReadable
     // is not reliable in PHP (hphp is fine) and buffered transport is more
     // efficient (60% faster in my tests)
     $transport = new TBufferedTransport($socket, $this->send_buffer_size, $this->recv_buffer_size);
     return $transport;
 }

开发者ID:jamescarr，项目名称:fbthrift，代码行数:18，代码来源:TServerSocket.php

注：本文中的TSocket类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

PHP TTDate类代码示例发布时间：2022-05-23

PHP TSession类代码示例发布时间：2022-05-23

kostub/iosMath: Beautiful math equation

1 GitbookIO/gitbook:

GitbookIO/gitbook:

阅读：957|2022-08-17

2 Delphi10.4.1在android平台下建立文件无权

TFileStream.Create(FInstallFileName, fmCreate or fmShareExclusive);这一句在an

阅读：607|2022-07-18

3 juleswhite/mobile-cloud-asgn1

juleswhite/mobile-cloud-asgn1

阅读：1032|2022-08-30

4 CVE-2022-29963

The Emerson DeltaV Distributed Control System (DCS) controllers and IO cards thr

阅读：960|2022-07-29

5 kyamagu/matlab-json: Use official API: h

kyamagu/matlab-json: Use official API: https://mathworks.com/help/matlab/json-fo

阅读：927|2022-08-17

6 墙壁眼睛膝盖

书名:墙壁眼睛膝盖作者:温柔一刀类别:欲望丛林，饮食男女。簡介:Wall(我)Eye(爱)Kn

阅读：657|2022-11-06

7 徘的拼音和组词，带徘字的词语大全

【徘】拼音：pi；笔画数：11；部首：彳；〔徘徊〕a.来回地走，如他在那里徘徘了很久;

阅读：811|2022-07-30

8 sevenjay/cpp-markdown: Cpp-Markdown is a

sevenjay/cpp-markdown: Cpp-Markdown is a freely-available Markdown text-to-HTML

阅读：582|2022-08-18

9 mathjax/MathJax-i18n: MathJax localizati

mathjax/MathJax-i18n: MathJax localization

阅读：388|2022-08-16

10 如何通过身份证号码看男女性别?

众所周知，我们的身份证号码里面包含的信息有很多，如出生日期、性别和识别码等，如果

阅读：252|2022-11-06

客服电话

电子邮件

PHP TSocket类代码示例

示例1: __construct

示例2: __construct

示例3: __get

示例4: __construct

示例5: getAiravataClient

示例6: add_node

示例7: getConnector

示例8: initialize

示例9: __construct

示例10: __construct

示例11: connect

示例12: __construct

示例13: connect

示例14: __construct

示例15: connect

示例16: accept

示例17: connect

示例18: connect

示例19: connect

示例20: accept

请发表评论

全部评论

上一篇：

下一篇：

krishnaik06/Machine-Learning-in-90-days

Arcensoth/mcdata: Version-controlled his

美元符号为什么是“$”

mmc-group/ML-for-materials-design

C语言小程序

kostub/iosMath: Beautiful math equation

MATLAB及其信号处理基础

pallet/zi: Maven plugin for clojure

CVE-2022-38625

CVE-2022-20220

jonathantribouharet/JTMaterialTransition

关于我们

产品与服务

解决方案

139-2527-9053