php语言的cmpp协议应用
2017-10-20 17:04
591 查看
因为公司网站需要移动物联卡的获取短信内容和发送短信功能,本人上网查了一下,发现几乎全是java语言的,只有两个文章是关于cmpp的php开发.而且只有发短信,还有问题.
这里将我开发的程序贴出来.代码也有些冗余,但功能都可以使用了.
我开发的应用接收短信和发送短信在不同的文件
接收短信是通过linux服务器screen来执行php文件获取短信.
发送短信是前端页面填入卡号和内容,传给后台去建立连接发送短信. (cmpp一个账号可以建立10个连接)
接收短信: 填入公司的接入码什么的,然后使用screen执行下面这个文件就可以了
<?php
class Cmpp {
// 设置项
public $host = ""; //服务商ip
public $port = "17890"; //端口号
public $Source_Addr = ""; //企业id 企业代码
public $Shared_secret = ''; //网关登录密码
public $Dest_Id = ""; //短信接入码 短信端口号
public $SP_ID = "";
public $SP_CODE = "";
public $Service_Id = "";
public $deliver;
private $socket;
private $Sequence_Id = 1;
private $bodyData;
private $AuthenticatorSource;
public $CMPP_CONNECT = 0x00000001; // 请求连接
public $CMPP_CONNECT_RESP = 0x80000001; // 请求连接
public $CMPP_DELIVER = 0x00000005; // 短信下发
public $CMPP_DELIVER_RESP = 0x80000005; // 下发短信应答
public $CMPP_ACTIVE_TEST = 0x00000008; // 激活测试
public $CMPP_ACTIVE_TEST_RESP = 0x80000008; // 激活测试应答
public $CMPP_SUBMIT = 0x00000004; // 短信发送
public $CMPP_SUBMIT_RESP = 0x80000004; // 发送短信应答
public static $msgid = 1;
public function createSocket(){
$this->socket =socket_create(AF_INET,SOCK_STREAM,SOL_TCP);
socket_connect($this->socket,$this->host, $this->port);
}
public function CMPP_CONNECT(){
date_default_timezone_set('PRC');
$Source_Addr = $this->Source_Addr;
$Version = 0x30;
$Timestamp = date('mdHis');
//echo $Timestamp;
$AuthenticatorSource = $this->createAS($Timestamp);
$bodyData = pack("a6a16CN", $Source_Addr, $AuthenticatorSource, $Version, $Timestamp);
$this->AuthenticatorSource = $AuthenticatorSource;
$this->send($bodyData, "CMPP_CONNECT");
}
public function CMPP_CONNECT_RESP(){
echo "connect success";
$body = unpack("CStatus/a16AuthenticatorISMG/CVersion", $this->bodyData);
}
public function send($bodyData, $Command,$Sequence=0){
$Command_Id=0x00000001;
if($Command =="CMPP_CONNECT"){
$Command_Id = 0x00000001;
}elseif($Command =="CMPP_DELIVER_RESP"){
$Command_Id = 0x80000005;
}elseif($Command =="CMPP_ACTIVE_TEST_RESP"){
$Command_Id = 0x80000008;
}elseif($Command =="CMPP_SUBMIT"){
$Command_Id = 0x00000004;
}
$Total_Length = strlen($bodyData) + 12;
if($Sequence==0){
if($this->Sequence_Id <10){
$Sequence_Id = $this->Sequence_Id;
}else{
$Sequence_Id =1;
$this->Sequence_Id=1;
}
$this->Sequence_Id = $this->Sequence_Id+1;
}else{
$Sequence_Id = $Sequence;
}
$headData = pack("NNN", $Total_Length, $Command_Id, $Sequence_Id);
// 发送消息
$this->log("send $Command_Id");
socket_write($this->socket, $headData.$bodyData, $Total_Length);
// $this->listen($Sequence_Id);
$i=1;
do{
$this->listen($Sequence_Id);
//$i = $i-1;
sleep(15);//等待时间，进行下一次操作
}while($i>0);
}
public function listen($Sequence_Id){
// 处理头
$headData = socket_read($this->socket, 12);
if(empty($headData)){
$this->log("0000");
return;
}
$head = unpack("NTotal_Length/NCommand_Id/NSequence_Id", $headData);
$this->log("get ".($head['Command_Id'] & 0x0fffffff));
$Sequence_Id = $head['Sequence_Id'];
// 处理body
$this->bodyData = socket_read($this->socket,$head['Total_Length'] - 12);
//var_dump($this->bodyData);
switch ( $head['Command_Id'] & 0x0fffffff ) {
case 0x00000001:
$this->CMPP_CONNECT_RESP();
break;
case 0x00000005:
$this->CMPP_DELIVER($head['Total_Length'],$Sequence_Id);
break;
case 0x80000005:
$this->CMPP_DELIVER($head['Total_Length'],$Sequence_Id);
break;
case 0x00000008:
$bodyData=pack("C",1); //数据联络包返回
$this->send($bodyData, "CMPP_ACTIVE_TEST_RESP",$Sequence_Id);
break;
default:
$bodyData=pack("C",1);
$this->send($bodyData, "CMPP_ACTIVE_TEST_RESP",$Sequence_Id);
break;
}
}
public function CMPP_DELIVER($Total_Length,$Sequence_Id){ //Msg_Id直接用N解析不行,N只有4位
$contentlen = $Total_Length-109;
$body = unpack("N2Msg_Id/a21Dest_Id/a10Service_Id/CTP_pid/CTP_udhi/CMsg_Fmt/a32Src_terminal_Id/CSrc_terminal_type/CRegistered_Delivery/CMsg_Length/a".$contentlen."Msg_Content/a20LinkID",$this->bodyData);
var_dump($body);
if($body['Msg_Length']>0){
$data = $body['Msg_Content'];
//$Msg_Id = $body['Msg_Id'];
$Msg_Id = ($body['Msg_Id1']& 0x0fffffff);
$Msg_Idfu = $body['Msg_Id2'];
$msgidz = unpack("N",substr($this->bodyData,0,8));
$msgidzz = '0000' .$msgidz[1];
mysql_connect('localhost','root','root123');
mysql_select_db('trace');
c8c6
mysql_query('set names utf8');
$data = trim($data);
$sql1 = "select id from socket_yd_msg where msgid='".$Msg_Id."'";
$chongfu = mysql_query($sql1);
$arrs =array();
while($arr= mysql_fetch_assoc($chongfu) ){
$arrs[] = $arr;
}
if( $arrs==array() || $arrs[0] == null ){
$sql = "insert into socket_yd_msg set msgid='".$Msg_Id."', content='".addslashes($data)."', add_time='".date('Y-m-d H:i:s')."'";
mysql_query($sql);
}
mysql_close();
//echo $Msg_Id."\n";
echo $data."\n";
echo $msgidzz."\n";
echo $Sequence_Id."\n";
$this->CMPP_DELIVER_RESP($msgidzz,$Msg_Idfu,$Sequence_Id);
}
}
// N打包只有4位
public function CMPP_DELIVER_RESP($Msg_Id,$Msg_Idfu,$Sequence_Id){
$sendda2 = 0x00;
$bodyData = pack("N", $Msg_Id).pack("N", $Msg_Idfu).pack("N",$sendda2);
$this->send($bodyData, "CMPP_DELIVER_RESP",$Sequence_Id);
}
/**AuthenticatorSource = MD5(Source_Addr+9 字节的0 +shared secret+timestamp) */
public function createAS($Timestamp){
$temp = $this->Source_Addr . pack("a9","") . $this->Shared_secret . $Timestamp;
return md5($temp, true);
}
/*** AuthenticatorISMG =MD5(Status + AuthenticatorSource + shared secret) */
public function cheakAISMG($Status, $AuthenticatorISMG){
$temp = $Status . $this->AuthenticatorSource . $this->Shared_secret;
$this->debug($temp.pack("a",""), 1, 1);
$this->debug($AuthenticatorISMG.pack("a",""), 2, 1);
if($AuthenticatorISMG != md5($temp, true)){
$this->throwErr("ISMG can't pass check .", __LINE__);
}
}
public function log($data, $line = null){
if($line){
$data = $line . " : ".$data;
}
file_put_contents("./cmpp.log", print_r($data, true).PHP_EOL, FILE_APPEND);
}
public function debug($data, $fileName, $noExit = false){
file_put_contents("./$fileName.debug", print_r($data, true));
if(!$noExit) exit;
}
public function throwErr($info, $line){
die("info: $info in line :$line");
}
}
@unlink("./cmpp.log");
$cmpp = new Cmpp;
$cmpp->createSocket();
$cmpp->CMPP_CONNECT();
?>
下面是发送短信: 前端部分就不发了,后端我也是用exec($str, $out, $res);来执行php文件,方便.
后台:
$tomsisdn = $_POST["tomsisdn"];
$contents = $_POST["contents"];
$str = "php -f /var/www/html/traceM2M/CmppSubmit.php {$tomsisdn} {$contents}";
//echo $str."\n";
exec($str, $out, $res);
if($res ==0)
echo $out[1];
//print_r($out);
<?php
class CMPPSubmit{
// 设置项
public $host = ""; //服务商ip
public $port = "17890"; //短连接端口号 17890长连接端口号
public $Source_Addr = ""; //企业id 企业代码
public $Shared_secret = ''; //网关登录密码
public $Dest_Id = ""; //短信接入码 短信端口号
public $SP_ID = "";
public $SP_CODE = "";
public $Service_Id = ""; //业务代码 这个是业务代码
public $deliver;
private $socket;
private $Sequence_Id = 1;
private $bodyData;
private $AuthenticatorSource;
public $CMPP_CONNECT = 0x00000001; // 请求连接
public $CMPP_CONNECT_RESP = 0x80000001; // 请求连接
public $CMPP_SUBMIT = 0x00000004; // 短信发送
public $CMPP_SUBMIT_RESP = 0x80000004; // 发送短信应答
public $CMPP_DELIVER = 0x00000005; // 短信下发
public $CMPP_DELIVER_RESP = 0x80000005; // 下发短信应答
public $CMPP_ACTIVE_TEST = 0x00000008; // 激活测试
public $CMPP_ACTIVE_TEST_RESP = 0x80000008; // 激活测试应答
public $msgid = 1;
public $tomsisdn = '';
public $contents = '';
public function __construct($argv1,$argv2){
if($argv1){
$this->tomsisdn = $argv1;
$this->contents = $argv2;
}else{
$this->log("has no canshu");exit;
}
}
public function createSocket(){
$this->socket =socket_create(AF_INET,SOCK_STREAM,SOL_TCP);
if(!$this->socket) {echo "can't creat socket";exit;}
$result = socket_connect($this->socket,$this->host, $this->port) or die(socket_strerror());
$this->CMPP_CONNECT();
}
public function CMPP_CONNECT(){
date_default_timezone_set('PRC');
$Source_Addr = $this->Source_Addr;
$Version = 0x30;
$Timestamp = date('mdHis');
//echo $Timestamp;
$AuthenticatorSource = $this->createAS($Timestamp);
$bodyData = pack("a6a16CN", $Source_Addr, $AuthenticatorSource, $Version, $Timestamp);
$this->AuthenticatorSource = $AuthenticatorSource;
$this->send($bodyData, "CMPP_CONNECT");
}
public function CMPP_CONNECT_RESP(){
echo "CMPP_CONNECT_RESP success \n";
$body = unpack("CStatus/a16AuthenticatorISMG/CVersion", $this->bodyData);
$this->CMPP_SUBMIT();
}
public function send($bodyData, $Command,$Sequence=0){
$Command_Id=0x00000001;
if($Command =="CMPP_CONNECT"){ //cmpp连接
$Command_Id = 0x00000001;
}elseif($Command =="CMPP_DELIVER_RESP"){ //下发应答
$Command_Id = 0x80000005;
}elseif($Command =="CMPP_ACTIVE_TEST_RESP"){ //数据链路应答
$Command_Id = 0x80000008;
}elseif($Command =="CMPP_SUBMIT"){ //发送短信
$Command_Id = 0x00000004;
}
$Total_Length = strlen($bodyData) + 12;
if($Sequence==0){
if($this->Sequence_Id <10){
$Sequence_Id = $this->Sequence_Id;
}else{
$Sequence_Id =1;
$this->Sequence_Id=1;
}
$this->Sequence_Id = $this->Sequence_Id+1;
}else{
$Sequence_Id = $Sequence;
}
$headData = pack("NNN", $Total_Length, $Command_Id, $Sequence_Id);
// 发送消息
$this->log("send $Command_Id");
socket_write($this->socket, $headData.$bodyData, $Total_Length);
$this->listen($Sequence_Id);
}
public function listen($Sequence_Id){
// 处理头
$headData = socket_read($this->socket, 12);
if(empty($headData)){
$this->log("0000");
return;
}
$head = unpack("NTotal_Length/NCommand_Id/NSequence_Id", $headData);
$this->log("get ".($head['Command_Id'] & 0x0fffffff));
$Sequence_Id = $head['Sequence_Id'];
// 处理body
$this->bodyData = socket_read($this->socket,$head['Total_Length'] - 12);
//var_dump($this->bodyData);
switch ( $head['Command_Id'] & 0x0fffffff ) {
case 0x00000001:
$this->CMPP_CONNECT_RESP();
break;
// case 0x00000005:
// $this->CMPP_DELIVER($head['Total_Length'],$Sequence_Id);
// break;
// case 0x80000005:
// $this->CMPP_DELIVER($head['Total_Length'],$Sequence_Id);
// break;
case 0x00000008:
$bodyData=pack("C",1); //数据联络包返回
$this->send($bodyData, "CMPP_ACTIVE_TEST_RESP",$Sequence_Id);
break;
case 0x00000004:
$this->CMPP_SUBMIT_RESP();
break;
// case 0x80000004:
// $this->CMPP_SUBMIT_RESP();
// break;
default:
$bodyData=pack("C",1);
$this->send($bodyData, "CMPP_ACTIVE_TEST_RESP",$Sequence_Id);
break;
}
}
public function CMPP_DELIVER($Total_Length,$Sequence_Id){ //Msg_Id直接用N解析不行
$contentlen = $Total_Length-109;
$body = unpack("N2Msg_Id/a21Dest_Id/a10Service_Id/CTP_pid/CTP_udhi/CMsg_Fmt/a32Src_terminal_Id/CSrc_terminal_type/CRegistered_Delivery/CMsg_Length/a".$contentlen."Msg_Content/a20LinkID",$this->bodyData);
var_dump($body);
if($body['Msg_Length']>0){
$data = $body['Msg_Content'];
//$Msg_Id = $body['Msg_Id'];
$Msg_Id = ($body['Msg_Id1']& 0x0fffffff);
$Msg_Idfu = $body['Msg_Id2'];
$msgidz = unpack("N",substr($this->bodyData,0,8));
$msgidzz = '0000' .$msgidz[1];
mysql_connect('localhost','root','root123');
mysql_select_db('trace');
mysql_query('set names utf8');
$data = trim($data);
$sql1 = "select id from socket_yd_msg where msgid='".$Msg_Id."'";
$chongfu = mysql_query($sql1);
$arrs =array();
while($arr= mysql_fetch_assoc($chongfu) ){
$arrs[] = $arr;
}
if( $arrs==array() || $arrs[0] == null ){
$sql = "insert into socket_yd_msg set msgid='".$Msg_Id."', content='".addslashes($data)."', add_time='".date('Y-m-d H:i:s')."'";
mysql_query($sql);
}
mysql_close();
//echo $Msg_Id."\n";
echo $data."\n";
echo $msgidzz."\n";
echo $Sequence_Id."\n";
$this->CMPP_DELIVER_RESP($msgidzz,$Msg_Idfu,$Sequence_Id);
}
}
// N打包只有4位
public function CMPP_DELIVER_RESP($Msg_Id,$Msg_Idfu,$Sequence_Id){
$sendda2 = 0x00;
$bodyData = pack("NNN", $Msg_Id, $Msg_Idfu,$sendda2);
$this->send($bodyData, "CMPP_DELIVER_RESP",$Sequence_Id);
}
public function CMPP_SUBMIT(){
$Msg_Id = rand(1,100);
//$bodyData = pack("a8", $Msg_Id);
$bodyData = pack("N", $Msg_Id).pack("N", "00000000");
$bodyData .= pack("C", 1).pack("C", 1);
$bodyData .= pack("C", 0).pack("C", 0);
$bodyData .= pack("a10", $this->Service_Id);
$bodyData .= pack("C", 0).pack("a32", "").pack("C", 0).pack("C", 0).pack("C", 0).pack("C", 0).pack("a6", $this->SP_ID).pack("a2", "02").pack("a6", "").pack("a17", "").pack("a17", "").pack("a21", $this->Dest_Id).pack("C", 1);
$bodyData .= pack("a32", $this->tomsisdn);
$bodyData .= pack("C", 0);
$len = strlen($this->contents);
$bodyData .= pack("C", $len);
$bodyData .= pack("a".$len, $this->contents);
$bodyData .= pack("a20", "00000000000000000000");
//echo '内容长度:包总长度-183='.(strlen($bodyData)-183)."字节\n";
$this->send($bodyData, "CMPP_SUBMIT",$Msg_Id);
}
public function CMPP_SUBMIT_RESP(){
echo "CMPP_SUBMIT_RESP success"."\n";
$body = unpack("N2Msg_Id/NResult",$this->bodyData);
print_r($body);
socket_close($this->socket);
}
/**AuthenticatorSource = MD5(Source_Addr+9 字节的0 +shared secret+timestamp) */
public function createAS($Timestamp){
$temp = $this->Source_Addr . pack("a9","") . $this->Shared_secret . $Timestamp;
return md5($temp, true);
}
public function log($data, $line = null){
if($line){
$data = $line . " : ".$data;
}
file_put_contents("./cmpp1.log", print_r($data, true).PHP_EOL, FILE_APPEND);
}
}
// @unlink("./cmpp1.log");
$cmpp = new CMPPSubmit($argv[1],$argv[2]);
$cmpp->createSocket();
// $cmpp->CMPP_CONNECT();
// $cmpp->CMPP_SUBMIT();
?>
基本就是这样
这里将我开发的程序贴出来.代码也有些冗余,但功能都可以使用了.
我开发的应用接收短信和发送短信在不同的文件
接收短信是通过linux服务器screen来执行php文件获取短信.
发送短信是前端页面填入卡号和内容,传给后台去建立连接发送短信. (cmpp一个账号可以建立10个连接)
接收短信: 填入公司的接入码什么的,然后使用screen执行下面这个文件就可以了
<?php
class Cmpp {
// 设置项
public $host = ""; //服务商ip
public $port = "17890"; //端口号
public $Source_Addr = ""; //企业id 企业代码
public $Shared_secret = ''; //网关登录密码
public $Dest_Id = ""; //短信接入码 短信端口号
public $SP_ID = "";
public $SP_CODE = "";
public $Service_Id = "";
public $deliver;
private $socket;
private $Sequence_Id = 1;
private $bodyData;
private $AuthenticatorSource;
public $CMPP_CONNECT = 0x00000001; // 请求连接
public $CMPP_CONNECT_RESP = 0x80000001; // 请求连接
public $CMPP_DELIVER = 0x00000005; // 短信下发
public $CMPP_DELIVER_RESP = 0x80000005; // 下发短信应答
public $CMPP_ACTIVE_TEST = 0x00000008; // 激活测试
public $CMPP_ACTIVE_TEST_RESP = 0x80000008; // 激活测试应答
public $CMPP_SUBMIT = 0x00000004; // 短信发送
public $CMPP_SUBMIT_RESP = 0x80000004; // 发送短信应答
public static $msgid = 1;
public function createSocket(){
$this->socket =socket_create(AF_INET,SOCK_STREAM,SOL_TCP);
socket_connect($this->socket,$this->host, $this->port);
}
public function CMPP_CONNECT(){
date_default_timezone_set('PRC');
$Source_Addr = $this->Source_Addr;
$Version = 0x30;
$Timestamp = date('mdHis');
//echo $Timestamp;
$AuthenticatorSource = $this->createAS($Timestamp);
$bodyData = pack("a6a16CN", $Source_Addr, $AuthenticatorSource, $Version, $Timestamp);
$this->AuthenticatorSource = $AuthenticatorSource;
$this->send($bodyData, "CMPP_CONNECT");
}
public function CMPP_CONNECT_RESP(){
echo "connect success";
$body = unpack("CStatus/a16AuthenticatorISMG/CVersion", $this->bodyData);
}
public function send($bodyData, $Command,$Sequence=0){
$Command_Id=0x00000001;
if($Command =="CMPP_CONNECT"){
$Command_Id = 0x00000001;
}elseif($Command =="CMPP_DELIVER_RESP"){
$Command_Id = 0x80000005;
}elseif($Command =="CMPP_ACTIVE_TEST_RESP"){
$Command_Id = 0x80000008;
}elseif($Command =="CMPP_SUBMIT"){
$Command_Id = 0x00000004;
}
$Total_Length = strlen($bodyData) + 12;
if($Sequence==0){
if($this->Sequence_Id <10){
$Sequence_Id = $this->Sequence_Id;
}else{
$Sequence_Id =1;
$this->Sequence_Id=1;
}
$this->Sequence_Id = $this->Sequence_Id+1;
}else{
$Sequence_Id = $Sequence;
}
$headData = pack("NNN", $Total_Length, $Command_Id, $Sequence_Id);
// 发送消息
$this->log("send $Command_Id");
socket_write($this->socket, $headData.$bodyData, $Total_Length);
// $this->listen($Sequence_Id);
$i=1;
do{
$this->listen($Sequence_Id);
//$i = $i-1;
sleep(15);//等待时间，进行下一次操作
}while($i>0);
}
public function listen($Sequence_Id){
// 处理头
$headData = socket_read($this->socket, 12);
if(empty($headData)){
$this->log("0000");
return;
}
$head = unpack("NTotal_Length/NCommand_Id/NSequence_Id", $headData);
$this->log("get ".($head['Command_Id'] & 0x0fffffff));
$Sequence_Id = $head['Sequence_Id'];
// 处理body
$this->bodyData = socket_read($this->socket,$head['Total_Length'] - 12);
//var_dump($this->bodyData);
switch ( $head['Command_Id'] & 0x0fffffff ) {
case 0x00000001:
$this->CMPP_CONNECT_RESP();
break;
case 0x00000005:
$this->CMPP_DELIVER($head['Total_Length'],$Sequence_Id);
break;
case 0x80000005:
$this->CMPP_DELIVER($head['Total_Length'],$Sequence_Id);
break;
case 0x00000008:
$bodyData=pack("C",1); //数据联络包返回
$this->send($bodyData, "CMPP_ACTIVE_TEST_RESP",$Sequence_Id);
break;
default:
$bodyData=pack("C",1);
$this->send($bodyData, "CMPP_ACTIVE_TEST_RESP",$Sequence_Id);
break;
}
}
public function CMPP_DELIVER($Total_Length,$Sequence_Id){ //Msg_Id直接用N解析不行,N只有4位
$contentlen = $Total_Length-109;
$body = unpack("N2Msg_Id/a21Dest_Id/a10Service_Id/CTP_pid/CTP_udhi/CMsg_Fmt/a32Src_terminal_Id/CSrc_terminal_type/CRegistered_Delivery/CMsg_Length/a".$contentlen."Msg_Content/a20LinkID",$this->bodyData);
var_dump($body);
if($body['Msg_Length']>0){
$data = $body['Msg_Content'];
//$Msg_Id = $body['Msg_Id'];
$Msg_Id = ($body['Msg_Id1']& 0x0fffffff);
$Msg_Idfu = $body['Msg_Id2'];
$msgidz = unpack("N",substr($this->bodyData,0,8));
$msgidzz = '0000' .$msgidz[1];
mysql_connect('localhost','root','root123');
mysql_select_db('trace');
c8c6
mysql_query('set names utf8');
$data = trim($data);
$sql1 = "select id from socket_yd_msg where msgid='".$Msg_Id."'";
$chongfu = mysql_query($sql1);
$arrs =array();
while($arr= mysql_fetch_assoc($chongfu) ){
$arrs[] = $arr;
}
if( $arrs==array() || $arrs[0] == null ){
$sql = "insert into socket_yd_msg set msgid='".$Msg_Id."', content='".addslashes($data)."', add_time='".date('Y-m-d H:i:s')."'";
mysql_query($sql);
}
mysql_close();
//echo $Msg_Id."\n";
echo $data."\n";
echo $msgidzz."\n";
echo $Sequence_Id."\n";
$this->CMPP_DELIVER_RESP($msgidzz,$Msg_Idfu,$Sequence_Id);
}
}
// N打包只有4位
public function CMPP_DELIVER_RESP($Msg_Id,$Msg_Idfu,$Sequence_Id){
$sendda2 = 0x00;
$bodyData = pack("N", $Msg_Id).pack("N", $Msg_Idfu).pack("N",$sendda2);
$this->send($bodyData, "CMPP_DELIVER_RESP",$Sequence_Id);
}
/**AuthenticatorSource = MD5(Source_Addr+9 字节的0 +shared secret+timestamp) */
public function createAS($Timestamp){
$temp = $this->Source_Addr . pack("a9","") . $this->Shared_secret . $Timestamp;
return md5($temp, true);
}
/*** AuthenticatorISMG =MD5(Status + AuthenticatorSource + shared secret) */
public function cheakAISMG($Status, $AuthenticatorISMG){
$temp = $Status . $this->AuthenticatorSource . $this->Shared_secret;
$this->debug($temp.pack("a",""), 1, 1);
$this->debug($AuthenticatorISMG.pack("a",""), 2, 1);
if($AuthenticatorISMG != md5($temp, true)){
$this->throwErr("ISMG can't pass check .", __LINE__);
}
}
public function log($data, $line = null){
if($line){
$data = $line . " : ".$data;
}
file_put_contents("./cmpp.log", print_r($data, true).PHP_EOL, FILE_APPEND);
}
public function debug($data, $fileName, $noExit = false){
file_put_contents("./$fileName.debug", print_r($data, true));
if(!$noExit) exit;
}
public function throwErr($info, $line){
die("info: $info in line :$line");
}
}
@unlink("./cmpp.log");
$cmpp = new Cmpp;
$cmpp->createSocket();
$cmpp->CMPP_CONNECT();
?>
下面是发送短信: 前端部分就不发了,后端我也是用exec($str, $out, $res);来执行php文件,方便.
后台:
$tomsisdn = $_POST["tomsisdn"];
$contents = $_POST["contents"];
$str = "php -f /var/www/html/traceM2M/CmppSubmit.php {$tomsisdn} {$contents}";
//echo $str."\n";
exec($str, $out, $res);
if($res ==0)
echo $out[1];
//print_r($out);
<?php
class CMPPSubmit{
// 设置项
public $host = ""; //服务商ip
public $port = "17890"; //短连接端口号 17890长连接端口号
public $Source_Addr = ""; //企业id 企业代码
public $Shared_secret = ''; //网关登录密码
public $Dest_Id = ""; //短信接入码 短信端口号
public $SP_ID = "";
public $SP_CODE = "";
public $Service_Id = ""; //业务代码 这个是业务代码
public $deliver;
private $socket;
private $Sequence_Id = 1;
private $bodyData;
private $AuthenticatorSource;
public $CMPP_CONNECT = 0x00000001; // 请求连接
public $CMPP_CONNECT_RESP = 0x80000001; // 请求连接
public $CMPP_SUBMIT = 0x00000004; // 短信发送
public $CMPP_SUBMIT_RESP = 0x80000004; // 发送短信应答
public $CMPP_DELIVER = 0x00000005; // 短信下发
public $CMPP_DELIVER_RESP = 0x80000005; // 下发短信应答
public $CMPP_ACTIVE_TEST = 0x00000008; // 激活测试
public $CMPP_ACTIVE_TEST_RESP = 0x80000008; // 激活测试应答
public $msgid = 1;
public $tomsisdn = '';
public $contents = '';
public function __construct($argv1,$argv2){
if($argv1){
$this->tomsisdn = $argv1;
$this->contents = $argv2;
}else{
$this->log("has no canshu");exit;
}
}
public function createSocket(){
$this->socket =socket_create(AF_INET,SOCK_STREAM,SOL_TCP);
if(!$this->socket) {echo "can't creat socket";exit;}
$result = socket_connect($this->socket,$this->host, $this->port) or die(socket_strerror());
$this->CMPP_CONNECT();
}
public function CMPP_CONNECT(){
date_default_timezone_set('PRC');
$Source_Addr = $this->Source_Addr;
$Version = 0x30;
$Timestamp = date('mdHis');
//echo $Timestamp;
$AuthenticatorSource = $this->createAS($Timestamp);
$bodyData = pack("a6a16CN", $Source_Addr, $AuthenticatorSource, $Version, $Timestamp);
$this->AuthenticatorSource = $AuthenticatorSource;
$this->send($bodyData, "CMPP_CONNECT");
}
public function CMPP_CONNECT_RESP(){
echo "CMPP_CONNECT_RESP success \n";
$body = unpack("CStatus/a16AuthenticatorISMG/CVersion", $this->bodyData);
$this->CMPP_SUBMIT();
}
public function send($bodyData, $Command,$Sequence=0){
$Command_Id=0x00000001;
if($Command =="CMPP_CONNECT"){ //cmpp连接
$Command_Id = 0x00000001;
}elseif($Command =="CMPP_DELIVER_RESP"){ //下发应答
$Command_Id = 0x80000005;
}elseif($Command =="CMPP_ACTIVE_TEST_RESP"){ //数据链路应答
$Command_Id = 0x80000008;
}elseif($Command =="CMPP_SUBMIT"){ //发送短信
$Command_Id = 0x00000004;
}
$Total_Length = strlen($bodyData) + 12;
if($Sequence==0){
if($this->Sequence_Id <10){
$Sequence_Id = $this->Sequence_Id;
}else{
$Sequence_Id =1;
$this->Sequence_Id=1;
}
$this->Sequence_Id = $this->Sequence_Id+1;
}else{
$Sequence_Id = $Sequence;
}
$headData = pack("NNN", $Total_Length, $Command_Id, $Sequence_Id);
// 发送消息
$this->log("send $Command_Id");
socket_write($this->socket, $headData.$bodyData, $Total_Length);
$this->listen($Sequence_Id);
}
public function listen($Sequence_Id){
// 处理头
$headData = socket_read($this->socket, 12);
if(empty($headData)){
$this->log("0000");
return;
}
$head = unpack("NTotal_Length/NCommand_Id/NSequence_Id", $headData);
$this->log("get ".($head['Command_Id'] & 0x0fffffff));
$Sequence_Id = $head['Sequence_Id'];
// 处理body
$this->bodyData = socket_read($this->socket,$head['Total_Length'] - 12);
//var_dump($this->bodyData);
switch ( $head['Command_Id'] & 0x0fffffff ) {
case 0x00000001:
$this->CMPP_CONNECT_RESP();
break;
// case 0x00000005:
// $this->CMPP_DELIVER($head['Total_Length'],$Sequence_Id);
// break;
// case 0x80000005:
// $this->CMPP_DELIVER($head['Total_Length'],$Sequence_Id);
// break;
case 0x00000008:
$bodyData=pack("C",1); //数据联络包返回
$this->send($bodyData, "CMPP_ACTIVE_TEST_RESP",$Sequence_Id);
break;
case 0x00000004:
$this->CMPP_SUBMIT_RESP();
break;
// case 0x80000004:
// $this->CMPP_SUBMIT_RESP();
// break;
default:
$bodyData=pack("C",1);
$this->send($bodyData, "CMPP_ACTIVE_TEST_RESP",$Sequence_Id);
break;
}
}
public function CMPP_DELIVER($Total_Length,$Sequence_Id){ //Msg_Id直接用N解析不行
$contentlen = $Total_Length-109;
$body = unpack("N2Msg_Id/a21Dest_Id/a10Service_Id/CTP_pid/CTP_udhi/CMsg_Fmt/a32Src_terminal_Id/CSrc_terminal_type/CRegistered_Delivery/CMsg_Length/a".$contentlen."Msg_Content/a20LinkID",$this->bodyData);
var_dump($body);
if($body['Msg_Length']>0){
$data = $body['Msg_Content'];
//$Msg_Id = $body['Msg_Id'];
$Msg_Id = ($body['Msg_Id1']& 0x0fffffff);
$Msg_Idfu = $body['Msg_Id2'];
$msgidz = unpack("N",substr($this->bodyData,0,8));
$msgidzz = '0000' .$msgidz[1];
mysql_connect('localhost','root','root123');
mysql_select_db('trace');
mysql_query('set names utf8');
$data = trim($data);
$sql1 = "select id from socket_yd_msg where msgid='".$Msg_Id."'";
$chongfu = mysql_query($sql1);
$arrs =array();
while($arr= mysql_fetch_assoc($chongfu) ){
$arrs[] = $arr;
}
if( $arrs==array() || $arrs[0] == null ){
$sql = "insert into socket_yd_msg set msgid='".$Msg_Id."', content='".addslashes($data)."', add_time='".date('Y-m-d H:i:s')."'";
mysql_query($sql);
}
mysql_close();
//echo $Msg_Id."\n";
echo $data."\n";
echo $msgidzz."\n";
echo $Sequence_Id."\n";
$this->CMPP_DELIVER_RESP($msgidzz,$Msg_Idfu,$Sequence_Id);
}
}
// N打包只有4位
public function CMPP_DELIVER_RESP($Msg_Id,$Msg_Idfu,$Sequence_Id){
$sendda2 = 0x00;
$bodyData = pack("NNN", $Msg_Id, $Msg_Idfu,$sendda2);
$this->send($bodyData, "CMPP_DELIVER_RESP",$Sequence_Id);
}
public function CMPP_SUBMIT(){
$Msg_Id = rand(1,100);
//$bodyData = pack("a8", $Msg_Id);
$bodyData = pack("N", $Msg_Id).pack("N", "00000000");
$bodyData .= pack("C", 1).pack("C", 1);
$bodyData .= pack("C", 0).pack("C", 0);
$bodyData .= pack("a10", $this->Service_Id);
$bodyData .= pack("C", 0).pack("a32", "").pack("C", 0).pack("C", 0).pack("C", 0).pack("C", 0).pack("a6", $this->SP_ID).pack("a2", "02").pack("a6", "").pack("a17", "").pack("a17", "").pack("a21", $this->Dest_Id).pack("C", 1);
$bodyData .= pack("a32", $this->tomsisdn);
$bodyData .= pack("C", 0);
$len = strlen($this->contents);
$bodyData .= pack("C", $len);
$bodyData .= pack("a".$len, $this->contents);
$bodyData .= pack("a20", "00000000000000000000");
//echo '内容长度:包总长度-183='.(strlen($bodyData)-183)."字节\n";
$this->send($bodyData, "CMPP_SUBMIT",$Msg_Id);
}
public function CMPP_SUBMIT_RESP(){
echo "CMPP_SUBMIT_RESP success"."\n";
$body = unpack("N2Msg_Id/NResult",$this->bodyData);
print_r($body);
socket_close($this->socket);
}
/**AuthenticatorSource = MD5(Source_Addr+9 字节的0 +shared secret+timestamp) */
public function createAS($Timestamp){
$temp = $this->Source_Addr . pack("a9","") . $this->Shared_secret . $Timestamp;
return md5($temp, true);
}
public function log($data, $line = null){
if($line){
$data = $line . " : ".$data;
}
file_put_contents("./cmpp1.log", print_r($data, true).PHP_EOL, FILE_APPEND);
}
}
// @unlink("./cmpp1.log");
$cmpp = new CMPPSubmit($argv[1],$argv[2]);
$cmpp->createSocket();
// $cmpp->CMPP_CONNECT();
// $cmpp->CMPP_SUBMIT();
?>
基本就是这样
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 
相关文章推荐
- PHP接口的概念跟接口语言与接口的应用场景
- PHP接口的概念跟接口语言与接口的应用场景
- PHP接口的概念跟接口语言与接口的应用场景
- PHP成为中国应用最广的Web开发语言
- PHP接口的概念跟接口语言与接口的应用场景
- 中国应用开源脚本语言PHP的水平如何?
- PHP成为中国应用最广的Web开发语言
- PHP接口的概念跟接口语言与接口的应用场景
- PHP接口的概念跟接口语言与接口的应用场景
- PHP接口的概念跟接口语言与接口的应用场景
- PHP接口的概念跟接口语言与接口的应用场景
- PHP接口的概念跟接口语言与接口的应用场景
- PHP接口的概念跟接口语言与接口的应用场景
- PHP语言中php curl的几种应用方式
- PHP接口的概念跟接口语言与接口的应用场景
- 内嵌式的语言PHP应用技巧七则
- window中使用memcache攻略（应用语言：PHP）
- 物联网需要什么样的应用开发语言？
- PHP Smarty通过gettext制作多语言版本
- JAVA与PHP语言比较