本文整理汇总了PHP中stream_context_set_option函数的典型用法代码示例。如果您正苦于以下问题：PHP stream_context_set_option函数的具体用法？PHP stream_context_set_option怎么用？PHP stream_context_set_option使用的例子？那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了stream_context_set_option函数的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的PHP代码示例。
示例1: send_to_ios
function send_to_ios($apnsHost, $apnsCertPath, $device_token, $data)
{
header('Content-Type: text/html; charset=UTF-8');
$deviceToken = $device_token;
/*
* $apnsHost
* development : gateway.sandbox.push.apple.com
* deployment : gateway.push.apple.com
*/
$apnsPort = 2195;
$alert = '';
if (array_key_exists('ios_alert', $data)) {
$alert = $data['ios_alert'];
}
$payload = array('aps' => array('alert' => $alert, 'badge' => 0, 'sound' => 'default'));
if (array_key_exists('ios_custom', $data)) {
$payload['ios_custom'] = $data['ios_custom'];
}
$payload = json_encode($payload);
$streamContext = stream_context_create();
stream_context_set_option($streamContext, 'ssl', 'local_cert', $apnsCertPath);
$apns = stream_socket_client('ssl://' . $apnsHost . ':' . $apnsPort, $error, $errorString, 2, STREAM_CLIENT_CONNECT, $streamContext);
if ($apns) {
$apnsMessage = chr(0) . chr(0) . chr(32) . pack('H*', str_replace(' ', '', $deviceToken)) . chr(0) . chr(strlen($payload)) . $payload;
fwrite($apns, $apnsMessage);
fclose($apns);
return TRUE;
}
//middle.error.log
MDI_Log::write('IOS_PUSH_ERROR-' . $this->input->ip_address() . '-' . $this->input->user_agent() . '-' . current_url());
return FALSE;
}
开发者ID:mehulsbhatt，项目名称:MDIgniter，代码行数:32，代码来源:pushmessage.php
示例2: sendPushOnServer
/**
* Send push notification
*/
function sendPushOnServer($device_token, $alert, $badge = null)
{
// Put private key's passphrase here:
$passphrase = "123456";
$liveMode = TRUE;
$url = $liveMode ? 'ssl://gateway.push.apple.com:2195' : 'ssl://gateway.sandbox.push.apple.com:2195';
// Put your alert message here:
//$message = 'Driver accept your request He will come soon!';
$ctx = stream_context_create();
stream_context_set_option($ctx, 'ssl', 'local_cert', 'pem/STKPEM.pem');
stream_context_set_option($ctx, 'ssl', 'passphrase', $passphrase);
// Open a connection to the APNS server
$fp = stream_socket_client($url, $err, $errstr, 60, STREAM_CLIENT_CONNECT | STREAM_CLIENT_PERSISTENT, $ctx);
if (!$fp) {
echo "Failed to connect: {$err} {$errstr}" . PHP_EOL;
die;
} else {
// Create the payload body
$body['aps'] = array('badge' => $badge, 'alert' => (string) $alert, 'sound' => "default");
// Encode the payload as JSON
$payload = json_encode($body);
// Build the binary notification
$msg = chr(0) . pack('n', 32) . pack('H*', $device_token) . pack('n', strlen($payload)) . $payload;
// echo $device_token;die;
// Send it to the server
$result = fwrite($fp, $msg, strlen($msg));
fclose($fp);
}
}
开发者ID:northoutAnil，项目名称:siezethekey，代码行数:32，代码来源:notification_model.php
示例3: sendMessage
/**
*
* @param array $dataMessage coleccion de parametros()
*/
public function sendMessage(array $dataMessage, array $dataConfig)
{
$context = stream_context_create();
stream_context_set_option($context, 'ssl', 'local_cert', $dataConfig['iphone']['pem']);
stream_context_set_option($context, 'ssl', 'passphrase', $dataConfig['iphone']['pass']);
$socket = stream_socket_client($dataConfig['iphone']['sandbox'], $err, $errstr, 60, STREAM_CLIENT_CONNECT | STREAM_CLIENT_PERSISTENT, $context);
if (!$socket) {
exit("Failed to connect: {$err} {$errstr}" . PHP_EOL);
} else {
}
$message = $dataMessage['message'];
$devices = $dataMessage['device'];
$payload['aps'] = array('alert' => $message, 'key' => $dataMessage['idpromotion']);
$payloadJSON = json_encode($payload);
for ($i = 0, $size = count($devices); $i < $size; $i++) {
$deviceToken = $devices[$i];
$payloadServer = chr(0) . pack('n', 32) . pack('H*', $deviceToken) . pack('n', strlen($payloadJSON)) . $payloadJSON;
$result = fwrite($socket, $payloadServer, strlen($payloadServer));
}
// if (!$result) {
// } else {
// }
fclose($socket);
return;
}
开发者ID:josmel，项目名称:HosPot，代码行数:29，代码来源:Ios.php
示例4: enviariOS
public function enviariOS($aMensajes)
{
$response = ['codigoerror' => 0, 'error' => '', 'data' => []];
try {
$streamContext = stream_context_create();
stream_context_set_option($streamContext, 'ssl', 'local_cert', $this->certificate);
if ($this->certificatepassword != '') {
stream_context_set_option($streamContext, 'ssl', 'passphrase', $this->certificatepassword);
}
$fp = stream_socket_client($this->url, $err, $errstr, 60, STREAM_CLIENT_CONNECT | STREAM_CLIENT_PERSISTENT, $streamContext);
if (!$fp) {
$response['codigoerror'] = 1;
$response['error'] = 'Error conectando a APNs: ' . $err;
return Response::json($response);
}
//En este punto ya estamos conectados al APN, mandamos todos los mensajes
foreach ($aMensajes as $mensaje) {
$payload['aps'] = ['alert' => $mensaje['mensaje'], 'badge' => 0, 'sound' => 'default'];
$jsonpayload = json_encode($payload);
$msg = chr(0) . pack('n', 32) . pack('H*', $mensaje['token']) . pack('n', strlen($jsonpayload)) . $jsonpayload;
$resultado = fwrite($fp, $msg, strlen($msg));
$response['data'][] = ['token' => $mensaje['token'], 'resultado' => $resultado];
}
return Response::json($response);
} catch (Exception $e) {
$response['codigoerror'] = 2;
$response['error'] = 'Error conectando a APNs: ' . $e->getMessage();
return Response::json($response);
}
}
开发者ID:csgt，项目名称:pushnotifications，代码行数:30，代码来源:Pushnotifications.php
示例5: sendIosPush
public function sendIosPush($registatoin_ids, $message, array $extra)
{
set_time_limit(0);
header('content-type: text/html; charset: utf-8');
$passphrase = 'password';
$deviceIds = $registatoin_ids;
//$message=json_encode($message);
//$payload = '{"aps":{"alert":"Hello","sound":"default","extra":"'.json_encode($message).'"}}';
$body['aps'] = array('alert' => $message, 'sound' => "default", 'extra' => json_encode($extra));
$payload = json_encode($body);
//$payload=json_encode($message);
$this->logger->write("INFO :", "inside ios payload" . $payload);
//$result = 'Start' . '<br />';
$ctx = stream_context_create();
stream_context_set_option($ctx, 'ssl', 'local_cert', 'ck.pem');
stream_context_set_option($ctx, 'ssl', 'passphrase', $passphrase);
foreach ($deviceIds as $item) {
//sleep(1);
$fp = stream_socket_client($this->iosServer, $err, $errstr, 60, STREAM_CLIENT_CONNECT | STREAM_CLIENT_PERSISTENT, $ctx);
// Build the binary notification
$msg = chr(0) . pack('n', 32) . pack('H*', $item) . pack('n', strlen($payload)) . $payload;
// Send it to the server
$result = fwrite($fp, $msg, strlen($msg));
if ($fp) {
fclose($fp);
}
}
//set_time_limit(30);
}
开发者ID:Rajeshwar90，项目名称:Referralio，代码行数:29，代码来源:iosPushUniversal.php
示例6: sendMessage
function sendMessage($latestWeibo)
{
$apnsCert = "ck.pem";
$pass = "123456";
$serverUrl = "ssl://gateway.sandbox.push.apple.com:2195";
//之后正式版了，每个用户一个deviceToken要写数据库里
//并且通过这个id区分发给哪个用户
$deviceToken = "865cbcd86a020c346550d2a543f9c2db8877f27023260024f0d9f1bb82802c77";
$badge = 1;
$sound = "default";
//中文乱码，要转一下字符集......
$message = iconv("GBK", "UTF-8", "【") . $latestWeibo->user->screen_name . iconv("GBK", "UTF-8", "】又发微博了： ") . $latestWeibo->text;
echo "</br> message send: {$message} </br>";
$body = array("aps" => array("alert" => $message, "badge" => $badge, "sound" => $sound));
$streamContext = stream_context_create();
stream_context_set_option($streamContext, "ssl", "local_cert", $apnsCert);
stream_context_set_option($streamContext, "ssl", "passphrase", $pass);
$apns = stream_socket_client($serverUrl, $error, $errorString, 60, STREAM_CLIENT_CONNECT | STREAM_CLIENT_PERSISTENT, $streamContext);
if (!$apns) {
echo "failed : {$error}, {$errorString} </br>";
}
$payload = json_encode($body);
$msg = chr(0) . pack('n', 32) . pack('H*', str_replace(' ', '', $deviceToken)) . pack('n', strlen($payload)) . $payload;
$result = fwrite($apns, $msg);
fclose($apns);
if ($result) {
echo "</br>sending successfully:</br> {$payload} </br>";
} else {
echo "send failed </br>";
}
}
开发者ID:ChesterYue，项目名称:SheSentWeibo，代码行数:31，代码来源:SheSendWeiboServer.php
示例7: pushNotification
/**
* Send Push Notification
*
* @param $sToken
* @param $message
* @return int
*/
public function pushNotification($sToken, $message)
{
//check if have push certificate key
$sDesUrl = PHPFOX_DIR . 'file' . PHPFOX_DS . 'accountapi' . PHPFOX_DS . 'certificate' . PHPFOX_DS . 'PushAppCerKey.pem';
if (file_exists($sDesUrl)) {
$ctx = stream_context_create();
stream_context_set_option($ctx, 'ssl', 'local_cert', $sDesUrl);
stream_context_set_option($ctx, 'ssl', 'passphrase', $this->_sPassPhrase);
stream_context_set_option($ctx, 'ssl', 'cafile', PHPFOX_DIR . 'file' . PHPFOX_DS . 'accountapi' . PHPFOX_DS . 'cert' . PHPFOX_DS . 'entrust_2048_ca.cer');
// Open a connection to the APNS server
$fp = stream_socket_client('ssl://' . $this->_sAPNSUrl, $err, $errstr, 30, STREAM_CLIENT_CONNECT | STREAM_CLIENT_PERSISTENT, $ctx);
if (!$fp) {
echo 'Failed to connect:' . $err . ' ' . $errstr;
return;
}
echo 'Connected to APNS' . PHP_EOL . $this->_sAPNSUrl;
// Create the payload body
$body['aps'] = $message;
// Encode the payload as JSON
$payload = json_encode($body);
// Build the binary notification
$msg = chr(0) . pack('n', 32) . pack('H*', $sToken) . pack('n', strlen($payload)) . $payload;
// Send it to the server
$result = fwrite($fp, $msg, strlen($msg));
// Close the connection to the server
fclose($fp);
return $result;
}
}
开发者ID:PhpFoxPro，项目名称:Better-Mobile-Module，代码行数:36，代码来源:apns.class.php
示例8: send_message
function send_message()
{
// Put your device token here (without spaces):
$device_token = $this->get_device_token();
// Put your private key's passphrase here:
$passphrase = $this->get_api_key();
// Put your alert message here:
$msg_data = $this->get_message();
$ctx = stream_context_create();
stream_context_set_option($ctx, 'ssl', 'local_cert', $this->certificate);
stream_context_set_option($ctx, 'ssl', 'passphrase', $passphrase);
// Open a connection to the APNS server
$fp = stream_socket_client($this->get_post_url(), $err, $errstr, 60, STREAM_CLIENT_CONNECT | STREAM_CLIENT_PERSISTENT, $ctx);
if (!$fp) {
exit("Failed to connect: {$err} {$errstr}" . PHP_EOL);
}
// Create the payload body
$body['aps'] = array('alert' => $msg_data['message'], 'badge' => 1, 'sound' => 'default');
$body['message'] = array('message_ID' => isset($msg_data['message_id']) ? $msg_data['message_id'] : '', 'message_title' => $msg_data['title'], 'message_type' => isset($msg_data['type']) ? $msg_data['type'] : '', 'message_shortDescription' => isset($msg_data['short_descr']) ? $msg_data['short_descr'] : '', 'message_date' => date('d/m/Y'));
// "message":{"message_ID":"1012","message_title":"push message","message_type":"push","message_shortDescription":"sample message","message_date": "12/05/2014"}}
// Encode the payload as JSON
$payload = json_encode($body);
// Build the binary notification
$msg = chr(0) . pack('n', 32) . pack('H*', $device_token) . pack('n', strlen($payload)) . $payload;
// Send it to the server
$result = fwrite($fp, $msg, strlen($msg));
/* if (!$result)
echo 'Message not delivered' . PHP_EOL;
else
echo 'Message successfully delivered' . PHP_EOL;*/
// Close the connection to the server
fclose($fp);
}
开发者ID:ashutoshdabral7，项目名称:VoyageUp_Server，代码行数:33，代码来源:Push_msg_ios.php
示例9: connect
/**
* Open the connection
*/
protected function connect($endpointType = Certificate::ENDPOINT_TYPE_GATEWAY)
{
$this->logger->debug('Connecting Apns\\SslSocket to the APNS ' . $endpointType . ' service with certificate "' . $this->getCertificate()->getDescription() . '"');
// Create the SSL context
$streamContext = stream_context_create();
stream_context_set_option($streamContext, 'ssl', 'local_cert', $this->certificate->getPemFile());
if ($this->certificate->hasPassphrase()) {
stream_context_set_option($streamContext, 'ssl', 'passphrase', $this->certificate->getPassphrase());
}
// Verify peer if an Authority Certificate is available
if (null !== $this->CACertificatePath) {
stream_context_set_option($streamContext, 'ssl', 'verify_peer', true);
stream_context_set_option($streamContext, 'ssl', 'cafile', $this->CACertificatePath);
}
// Open the connection
$errorCode = $errorString = null;
$this->connection = @stream_socket_client($this->certificate->getEndpoint($endpointType), $errorCode, $errorString, $this->connectTimeout, STREAM_CLIENT_CONNECT, $streamContext);
// Check if the connection succeeded
if (false == $this->connection) {
$this->connection = null;
// Set a somewhat more clear error message on error 0
if (0 == $errorCode) {
$errorString = 'Error before connecting, please check your certificate and passphrase combo and the given CA certificate if any.';
}
throw new \UnexpectedValueException('Failed to connect to ' . $this->certificate->getEndpoint($endpointType) . ' with error #' . $errorCode . ' "' . $errorString . '".');
}
// Set stream in non-blocking mode and make writes unbuffered
stream_set_blocking($this->connection, 0);
stream_set_write_buffer($this->connection, 0);
}
开发者ID:zhangxiaoliu，项目名称:notificato，代码行数:33，代码来源:SslSocket.php
示例10: sendMessageIos
/**
* For IOS APNS
* $params["msg"] : Expected Message For APNS
*/
private function sendMessageIos($registration_id, $params)
{
$ssl_url = 'ssl://gateway.push.apple.com:2195';
//$ssl_url = 'ssl://gateway.sandbox.push.apple.com:2195; //For Test
$payload = array();
$payload['aps'] = array('alert' => array("body" => $params["msg"], "action-loc-key" => "View"), 'badge' => 0, 'sound' => 'default');
## notice : alert, badge, sound
## $payload['extra_info'] is different from what your app is programmed, this extra_info transfer to your IOS App
$payload['extra_info'] = array('apns_msg' => $params["msg"]);
$push = json_encode($payload);
//Create stream context for Push Sever.
$streamContext = stream_context_create();
stream_context_set_option($streamContext, 'ssl', 'local_cert', $this->iosCert);
$apns = stream_socket_client($ssl_url, $error, $errorString, 60, STREAM_CLIENT_CONNECT, $streamContext);
if (!$apns) {
$rtn["code"] = "001";
$rtn["msg"] = "Failed to connect " . $error . " " . $errorString;
return $rtn;
}
//echo 'error=' . $error;
$t_registration_id = str_replace('%20', '', $registration_id);
$t_registration_id = str_replace(' ', '', $t_registration_id);
$apnsMessage = chr(0) . chr(0) . chr(32) . pack('H*', str_replace(' ', '', $t_registration_id)) . chr(0) . chr(strlen($push)) . $push;
$writeResult = fwrite($apns, $apnsMessage);
fclose($apns);
$rtn["code"] = "000";
//means result OK
$rtn["msg"] = "OK";
return $rtn;
}
开发者ID:fgh151，项目名称:yii2-push，代码行数:34，代码来源:Module.php
示例11: SendUserOrderMessage
public function SendUserOrderMessage($order, $message)
{
$user = $order->user->get();
$user_apn_token = UserApnToken::getInstanceByUserID($user->getID());
if (!isset($user_apn_token)) {
return false;
}
$deviceToken = str_replace(' ', '', $user_apn_token->token->get());
$ctx = stream_context_create();
stream_context_set_option($ctx, 'ssl', 'local_cert', getcwd() . '/apple_apn/IlluminataDevCerAndKey.pem');
stream_context_set_option($ctx, 'ssl', 'passphrase', AppleAPNService::$passphrase);
$fp = stream_socket_client('ssl://gateway.sandbox.push.apple.com:2195', $err, $errstr, 60, STREAM_CLIENT_CONNECT | STREAM_CLIENT_PERSISTENT, $ctx);
if (!$fp) {
throw new Exception("Failed to connect: {$err} {$errstr}" . PHP_EOL);
}
$body['aps'] = array('alert' => $message, 'title' => 'Order message', 'type' => strval(AppleAPNService::$MESSAGE_TYPE_USER_ORDER_MESSAGE), 'targetID' => $order->getID(), 'url' => 'http://www.illuminataeyewear.com', 'sound' => 'default');
$payload = json_encode($body);
$msg = chr(0) . pack('n', 32) . pack('H*', $deviceToken) . pack('n', strlen($payload)) . $payload;
$result = fwrite($fp, $msg, strlen($msg));
fclose($fp);
if (!$result) {
return false;
} else {
return true;
}
//throw new Exception('Message successfully delivered' . PHP_EOL);
}
开发者ID:saiber，项目名称:www，代码行数:27，代码来源:AppleAPNService.php
示例12: reloadUsingStream
private function reloadUsingStream()
{
//$this->reloadUsingSocket();
//return;
$transport = $this->scheme == 'http' ? 'tcp' : 'ssl';
$addr = $this->host;
if ($transport == 'ssl') {
$context = stream_context_create();
stream_context_set_option($context, 'ssl', 'verify_host', true);
stream_context_set_option($context, 'ssl', 'allow_self_signed', true);
$fp = @stream_socket_client("{$transport}://{$addr}:" . $this->port, $errno, $errstr, 15, STREAM_CLIENT_CONNECT, $context);
} else {
$fp = @stream_socket_client("{$transport}://{$addr}:" . $this->port, $errno, $errstr, 15, STREAM_CLIENT_CONNECT);
}
if ($fp === false) {
return false;
}
$url = $this->uri;
if (strpos($url, '?action=backup_guard_manualBackup') === FALSE) {
$url .= '?action=backup_guard_manualBackup';
}
$out = "GET " . $url . " HTTP/1.1\r\n";
$out .= "Host: " . $this->host . "\r\n";
$out .= "Connection: Close\r\n\r\n";
@fwrite($fp, $out);
sleep(1);
@fclose($fp);
}
开发者ID:Finzy，项目名称:stageDB，代码行数:28，代码来源:SGReloadHandler.php
示例13: query
public function query($query = null)
{
$status = self::STATUS_NOTCONNECTED;
$context = $this->_connection;
$wrapper = $this->config('wrapper');
if ($context) {
if (DevValue::isNotNull($query)) {
if (DevArray::isAssoc($query)) {
$this->_data = $query;
} else {
if (is_string($query)) {
$data = urlencode($query);
stream_context_set_option($context, $wrapper, 'content', $data);
$this->_result = file_get_contents($target, false, $context);
$this->status($this->_result !== false ? self::STATUS_SUCCESS : self::STATUS_FAILED);
return true;
}
}
}
$data = HTTP::query($this->_data);
stream_context_set_option($context, $wrapper, 'content', $data);
$this->_result = file_get_contents($target, false, $context);
if ($this->_result !== false) {
$status = self::STATUS_SUCCESS;
}
}
$this->status($status);
}
开发者ID:bluefission，项目名称:DevElation，代码行数:28，代码来源:Stream.php
示例14: sendNotification
public static function sendNotification($device_token, $message)
{
$passphrase = 'meboopush';
// echo dirname(__FILE__) . 'PushNotificationMeboo.pem'; die;
$ctx = stream_context_create();
stream_context_set_option($ctx, 'ssl', 'local_cert', dirname(__FILE__) . '/PushMebooProduction.pem');
stream_context_set_option($ctx, 'ssl', 'passphrase', $passphrase);
// Open a connection to the APNS server
$fp = stream_socket_client('ssl://gateway.push.apple.com:2195', $err, $errstr, 60, STREAM_CLIENT_CONNECT | STREAM_CLIENT_PERSISTENT, $ctx);
if (!$fp) {
exit("Failed to connect: {$err} {$errstr}" . PHP_EOL);
}
// echo 'Connected to APNS' . PHP_EOL;
// Create the payload body
$body['aps'] = $message;
// Encode the payload as JSON
$payload = json_encode($body);
// Build the binary notification
$msg = chr(0) . pack('n', 32) . pack('H*', $device_token) . pack('n', strlen($payload)) . $payload;
// Send it to the server
$result = fwrite($fp, $msg, strlen($msg));
if (!$result) {
// echo 'Message not delivered' . PHP_EOL;
} else {
// echo 'Message successfully delivered' . PHP_EOL;
}
// Close the connection to the server
fclose($fp);
}
开发者ID:huynt57，项目名称:medlatec，代码行数:29，代码来源:IosPushHelper.php
示例15: proxy
/**
* Send proxy request
*
* @param peer.Socket $s Connection to proxy
* @param peer.http.HttpRequest $request
* @param peer.URL $url
*/
protected function proxy($s, $request, $url)
{
static $methods = ['tls://' => STREAM_CRYPTO_METHOD_TLS_CLIENT, 'sslv3://' => STREAM_CRYPTO_METHOD_SSLv3_CLIENT, 'sslv23://' => STREAM_CRYPTO_METHOD_SSLv23_CLIENT, 'sslv2://' => STREAM_CRYPTO_METHOD_SSLv2_CLIENT];
$connect = sprintf("CONNECT %1\$s:%2\$d HTTP/1.1\r\nHost: %1\$s:%2\$d\r\n\r\n", $url->getHost(), $url->getPort(443));
$this->cat && $this->cat->info('>>>', substr($connect, 0, strpos($connect, "\r")));
$s->write($connect);
$handshake = $s->read();
if (4 === ($r = sscanf($handshake, "HTTP/%*d.%*d %d %[^\r]", $status, $message))) {
while ($line = $s->readLine()) {
$handshake .= $line . "\n";
}
$this->cat && $this->cat->info('<<<', $handshake);
if (200 === $status) {
stream_context_set_option($s->getHandle(), 'ssl', 'peer_name', $url->getHost());
if (isset($methods[$this->socket->_prefix])) {
$this->enable($s, [$this->socket->_prefix => $methods[$this->socket->_prefix]]);
} else {
$this->enable($s, $methods);
}
} else {
throw new \io\IOException('Cannot connect through proxy: #' . $status . ' ' . $message);
}
} else {
throw new \io\IOException('Proxy did not answer with valid HTTP: ' . $handshake);
}
}
开发者ID:xp-framework，项目名称:http，代码行数:33，代码来源:SSLSocketHttpTransport.class.php
示例16: sendNotification
function sendNotification($deviceToken, $message, $badges)
{
// Put your private key's passphrase here:
$passphrase = 'stmwtxvp';
// Put your alert message here:
$message = 'New tickets have been received!';
////////////////////////////////////////////////////////////////////////////////
$ctx = stream_context_create();
stream_context_set_option($ctx, 'ssl', 'local_cert', 'apns-dev.pem');
stream_context_set_option($ctx, 'ssl', 'passphrase', $passphrase);
// Open a connection to the APNS server
$fp = stream_socket_client('ssl://gateway.sandbox.push.apple.com:2195', $err, $errstr, 60, STREAM_CLIENT_CONNECT | STREAM_CLIENT_PERSISTENT, $ctx);
if (!$fp) {
exit("Failed to connect: {$err} {$errstr}" . PHP_EOL);
}
echo 'Connected to APNS' . PHP_EOL;
// Create the payload body
$body['aps'] = array('alert' => $message, 'sound' => 'default', 'badge' => 1);
// Encode the payload as JSON
$payload = json_encode($body);
// Build the binary notification
$msg = chr(0) . pack('n', 32) . pack('H*', $deviceToken) . pack('n', strlen($payload)) . $payload;
// Send it to the server
$result = fwrite($fp, $msg, strlen($msg));
if (!$result) {
echo 'SUCCESS' . PHP_EOL;
} else {
echo 'FAILED' . PHP_EOL;
}
// Close the connection to the server
fclose($fp);
}
开发者ID:archelaus，项目名称:smartphp，代码行数:32，代码来源:iospush.php
示例17: iosPush
function iosPush($token)
{
try {
$deviceToken = $token;
$message = 'You are not connected to personnel Tracker! Connect with tracker to continue the service.';
$body['aps'] = array('alert' => $message, 'badge' => 18);
$body['category'] = 'message';
$passphrase = 'personneltracker';
$ctx = stream_context_create();
stream_context_set_option($ctx, 'ssl', 'local_cert', 'ckDistNew.pem');
stream_context_set_option($ctx, 'ssl', 'passphrase', $passphrase);
$fp = stream_socket_client('ssl://gateway.sandbox.push.apple.com:2195', $err, $errstr, 60, STREAM_CLIENT_CONNECT | STREAM_CLIENT_PERSISTENT, $ctx);
if (!$fp) {
exit("Failed to connect: {$err} {$errstr}" . PHP_EOL);
}
echo 'Connected to APNS' . PHP_EOL;
$payload = json_encode($body);
// Build the binary notification
$msg = chr(0) . pack('n', 32) . pack('H*', $deviceToken) . pack('n', strlen($payload)) . $payload;
// Send it to the server
$result = fwrite($fp, $msg, strlen($msg));
if (!$result) {
echo 'Message not delivered' . PHP_EOL;
} else {
echo 'Message successfully delivered' . PHP_EOL;
}
fclose($fp);
} catch (Exception $e) {
echo $e->getMessage();
}
}
开发者ID:nimitshukla123，项目名称:personnelTracker，代码行数:31，代码来源:pushNotification.php
示例18: openSocket
/**
* Return a socket object
*/
function openSocket($proto, $conf)
{
$errLevel = error_reporting();
error_reporting(0);
if ($proto != "ssl://" || $conf[$_SESSION["agent"]]["verifypeer"] != 1 || !function_exists("stream_socket_client")) {
/*
Not a SSL connection,
or simple SSL connection without client certificate and server
certificate check
or stream_socket_client function not available (PHP 5 only),
*/
$sock = fsockopen($proto . $_SESSION["XMLRPC_agent"]["host"], $_SESSION["XMLRPC_agent"]["port"], $errNo, $errString);
$ret = array($sock, $errNo, $errString);
} else {
$context = stream_context_create();
stream_context_set_option($context, "ssl", "allow_self_signed", False);
stream_context_set_option($context, "ssl", "verify_peer", True);
stream_context_set_option($context, "ssl", "cafile", $conf[$_SESSION["agent"]]["cacert"]);
stream_context_set_option($context, "ssl", "local_cert", $conf[$_SESSION["agent"]]["localcert"]);
$sock = stream_socket_client('tls://' . $_SESSION["XMLRPC_agent"]["host"] . ":" . $_SESSION["XMLRPC_agent"]["port"], $errNo, $errString, ini_get("default_socket_timeout"), STREAM_CLIENT_CONNECT, $context);
$ret = array($sock, $errNo, $errString);
}
error_reporting($errLevel);
if ($sock !== False) {
/* Setting timeout on a SSL socket only works with PHP >= 5.2.1 */
stream_set_timeout($sock, $conf[$_SESSION["agent"]]["timeout"]);
}
return $ret;
}
开发者ID:sebastiendu，项目名称:mmc，代码行数:32，代码来源:xmlrpc.inc.php
示例19: __construct
public function __construct(array $config = [])
{
$this->smsc_host = $config['SMSC_HOST'];
$this->smsc_port = $config['SMSC_PORT'];
$this->smsc_ssl_port = $config['SMSC_SSL_PORT'];
$this->smsc_login = $config['SMSC_LOGIN'];
$this->smsc_password = $config['SMSC_PASSWORD'];
$this->smsc_charset = $config['SMSC_CHARSET'];
$this->smsc_use_ssl = $config['SMSC_USE_SSL'] ?: false;
$ip = gethostbyname($this->smsc_host);
if ($ip == $this->smsc_host) {
// dns fail
$ip = "212.24.33.196";
}
// fixed ip
$protocol = $this->smsc_use_ssl ? 'ssl://' : '';
$port = $this->smsc_use_ssl ? $this->smsc_ssl_port : $this->smsc_port;
if ($this->smsc_use_ssl) {
$context = stream_context_create();
stream_context_set_option($context, 'ssl', 'verify_host', false);
stream_context_set_option($context, 'ssl', 'verify_peer', false);
stream_context_set_option($context, 'ssl', 'verify_peer_name', false);
stream_context_set_option($context, 'ssl', 'allow_self_signed', true);
} else {
$context = null;
}
$this->socket = stream_socket_client($protocol . $ip . ":" . $port, $errno, $errstr, 30, STREAM_CLIENT_CONNECT, $context);
if (!$this->socket) {
die("Не могу соединиться: {$errstr} ({$errno})");
}
if (!$this->bind()) {
throw new \RuntimeException('Socket Error');
}
}
开发者ID:shatilov，项目名称:simple-sms，代码行数:34，代码来源:SmscSmppSMS.php
示例20: __construct
/**
* Class constructor, tries to establish connection
*
* @param string $address Address for stream_socket_client() call,
* e.g. 'tcp://localhost:80'
* @param int $timeout Connection timeout (seconds)
* @param array $contextOptions Context options
*
* @throws HTTP_Request2_LogicException
* @throws HTTP_Request2_ConnectionException
*/
public function __construct($address, $timeout, array $contextOptions = array())
{
if (!empty($contextOptions) && !isset($contextOptions['socket']) && !isset($contextOptions['ssl'])) {
// Backwards compatibility with 2.1.0 and 2.1.1 releases
$contextOptions = array('ssl' => $contextOptions);
}
$context = stream_context_create();
foreach ($contextOptions as $wrapper => $options) {
foreach ($options as $name => $value) {
if (!stream_context_set_option($context, $wrapper, $name, $value)) {
throw new HTTP_Request2_LogicException("Error setting '{$wrapper}' wrapper context option '{$name}'");
}
}
}
set_error_handler(array($this, 'connectionWarningsHandler'));
$this->socket = stream_socket_client($address, $errno, $errstr, $timeout, STREAM_CLIENT_CONNECT, $context);
restore_error_handler();
// if we fail to bind to a specified local address (see request #19515),
// connection still succeeds, albeit with a warning. Throw an Exception
// with the warning text in this case as that connection is unlikely
// to be what user wants and as Curl throws an error in similar case.
if ($this->connectionWarnings) {
if ($this->socket) {
fclose($this->socket);
}
$error = $errstr ? $errstr : implode("\n", $this->connectionWarnings);
throw new HTTP_Request2_ConnectionException("Unable to connect to {$address}. Error: {$error}", 0, $errno);
}
}
开发者ID:aim-web-projects，项目名称:kobe-chuoh，代码行数:40，代码来源:SocketWrapper.php
注：本文中的stream_context_set_option函数示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论