- 論壇徽章:
- 0
|
linux_c_py_php 發(fā)表于 2012-09-25 17:33 ![]()
為什么php是用curl請求php worker呢, gearmand不是有開發(fā)接口嗎, 你這個中途又走了什么中間代理嗎
oh， 是這樣，我這是一個計數器，類似文章點擊率或者微博粉絲數目什么的，是提供 web serviec api的方式：
前端開發(fā)人員 功過 ajax，curl的get或者post方式傳送數據給php腳本服務端，然后我在服務端腳本里接受參數
，我上代碼吧！- class Hit extends CI_Controller {
- private $_data=array();
- private function _echo($msg="ok",$errno=1,$data=array()){
- $re = array();
- $re['msg']=$msg;
- $re['state']=$errno;
- $re['data']=$data;
- $this->re_json($this->_data['callback'],json_encode($re));
- exit;
- }
- private function re_json($callback,$json_re)
- {
- //__DEBUG__ AND $json_re="'".$json_re."'";
- $this->_data['fe_debug'] AND $json_re="'".$json_re."'";
- if($callback){
- echo $callback."(".$json_re.")";
- }else{
- echo $json_re;
- }
- }
- private function init(){
- $this->_data['callback']="";
- $this->_data['platform_name']="";
- $this->_data['platform_id']=0;
- $this->_data['object_id'] =0;
- $this->_data['event_id'] = 0;
- $this->_data['fe_debug']=0;
- }
- public function insert(){//new_click
- $this->init();
- isset($_REQUEST['callback']) AND $this->_data['callback']=$_REQUEST['callback'];
- isset($_REQUEST['debug']) AND $this->_data['fe_debug']=intval($_REQUEST['debug']);
- $data = array();
- isset($_REQUEST['callback']) AND $data= $this->input->get();
- $data OR $data = $this->input->post();
- $data OR $data = $this->uri->uri_to_assoc();
- $data = $this->check_data($data);
- $data_=array();
- $data_['platform_id']=$data['platform_id'];
- $data_['object_id']=$data['object_id'];
- $data_['event_id']=$data['event_id'];
- $this->in_queue($data_);
- }
- private function check_data($data){
- if(empty($data) OR !is_array($data)){
- $this->_echo("no any data","-400");
- }
- $event_id=0;
- $object_id=0;
- $platform_name="";
- extract($data);
- //isset($callback) AND $this->_data['callback']=$callback;
- isset($platform_name) AND $this->_data['platform_name']=$platform_name;
- isset($object_id) AND $this->_data['object_id']=intval($object_id);
- isset($event_id) AND $this->_data['event_id']=intval($event_id);
- if(!$this->_data['platform_name']){
- $this->_echo("platform_name is NULL",-5);
- }
- //print_r($event_id);
- global $g_platform_list,$g_event_list;
- if(!$platform_id=array_search($platform_name,$g_platform_list)){
- $this->_echo("platform_name error",-1);
- }
- if(!array_key_exists( intval($event_id),$g_event_list) ){
- $this->_echo("event_id error",-2);
- }
- if(!intval($object_id)){
- $this->_echo("object_id error",-3);
- }
- $this->_data['platform_id']=$platform_id;
- return $this->_data;
- }
- private function in_queue($data){
- global $g_gearman;
- $client = new GearmanClient();
- foreach($g_gearman as $key=>$v){
- $tmp_array = explode(":",$v);
- $client->addServer($tmp_array[0],$tmp_array[1]);
- }
- $str = json_encode($data);
- $client->doBackground("in_queue_now",$str);
- if($client->returnCode() != GEARMAN_SUCCESS){
- $this->_echo("gearman error",-500);
- }
- __DEBUG__ AND $this->_echo("ok",1,$data);
- __DEBUG__ OR $this->_echo("ok",1);
- }
- }
- private function in_queue($data){
- global $g_gearman;
- $client = new GearmanClient();
- foreach($g_gearman as $key=>$v){
- $tmp_array = explode(":",$v);
- $client->addServer($tmp_array[0],$tmp_array[1]);
- }
- $str = json_encode($data);
- $client->doBackground("in_queue_now",$str);
- if($client->returnCode() != GEARMAN_SUCCESS){
- $this->_echo("gearman error",-500);
- }
in_queue 這個私有成員方法里面加入geamand服務器然后 處理的，然后另外一臺服務器在從消息隊列里面取出數據插入mongo，謝謝跟進！
|
|
免費注冊
發(fā)表于 2012-09-24 18:11
