PHP与C(或其它语言)通过消息队列进行通讯，完整代码

jackxiang 2012-11-5 13:50

通过消息队列确实是一个PHP和C进行通讯的除开共享内存外的一个好方法，如下：
msg.php

<?php
/*
 * class msg
 * Use for communication between php and php;
 * Create at: 12:08 2012/10/31
 * Author: leixun(lein_urg@163.com)
 * version 1 - 14:01 2012/10/31
 */

class msg{
  private $id;
  private $msg_id;
  private $_serialize = true;

/**
   * @param $_id ID
   */
  public function msg($_id, $_serialize = true){
    if(!function_exists('msg_get_queue'))
    {
      die('msg queue function not installed, Reconfigure PHP with --enable-sysvmsg <br/>');
    }
    $this->id = $_id;
    $this->msg_id = msg_get_queue ( $_id );
    $this->_serialize = $_serialize;
    if ($this->msg_id === false) {
      die(basename(__FILE__).'->'.__LINE__.': Unable to create message quee');
    }
  }

/**
   * @data data to send
   * @type message type
   */
  public function send( $data, $type = 1, $blocking = false )
  {
    if (!msg_send ($this->msg_id, $type, $data, $this->_serialize, $blocking, $msg_err))
    {
      return "Msg not sent because $msg_err\n";
    }
    return true;
  }

/**
   * @param $type message type
   * @param $maxsize The maximum size of message to be accepted,
   */
  public function receive($no_wait = true, $type = 1 , $maxsize = 1024 )
  {
    $rs = msg_receive ( $this->msg_id , $type ,  $type , $maxsize , $message , $this->_serialize, $no_wait?MSG_IPC_NOWAIT:NULL , $errorcode);
    if($rs)
      return $message;
    else
      return false;
  }

public function remove()
  {
    msg_remove_queue($this->msg_id);
  }  
}

msg_write.php

msg.c

#include <stdio.h>
#include <errno.h>

#include <stdlib.h>
#include <fcntl.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#define MAX_MSG_LEN 512
static int php_msg = -1;
static int php_msg1 = -1;

static int running = 1;

static void *php_msg_handler_thread(void *arg);
static int msg_send(int msg_id, int fd, char *data);

struct msg_st {
  long mtype;
  char mtext[MAX_MSG_LEN];
};

int main(int argc,char **argv)
{
  printf("go 1 \n");

if((php_msg= msgget((key_t)1,0666|IPC_CREAT)) == -1)
  {
    perror("php_msg create");
    return 0;
  }
  
  if((php_msg1= msgget((key_t)2,0666|IPC_CREAT)) == -1)
  {
    perror("php_msg create");
    return 0;
  }

/////////////////////////////////////////////////////////////////////////////////
  pthread_t php_msg_pthread;

int rs = pthread_create(&php_msg_pthread, NULL, (void*(*)(void*))php_msg_handler_thread, (void *)NULL);
  if(rs!=0)
  {
    perror("php_msg_pthread create");
    return 0;
  }

pthread_join(php_msg_pthread, NULL);
  return 0;

}

static void *php_msg_handler_thread(void *arg)
{
  struct msg_st php_data;    
  printf("sizeof(struct msg_st)=%d\n",sizeof(struct msg_st));

char* data;
  data = malloc(MAX_MSG_LEN);
  char *pre = "You told me:";  
  while(running){
    //ssize_t msgrcv(int msqid, void *msgp, size_t msgsz, long msgtyp, int msgflg); 
    if(msgrcv(php_msg,(void *) &php_data, MAX_MSG_LEN, 0 , 0) == -1)
    {
      perror("msgrcv");
      if(errno==E2BIG)
      {        
        if(msgctl(php_msg,IPC_RMID,0) == -1)  
        {  
          fprintf(stderr,"msgctl(IPC_RMID) failed \n");  
        }   
      }
      else if(errno == EINVAL)
      {
        sleep(1);
      }
    }else{    
      printf("recevier mssage : %s , type= %d\n", php_data.mtext, php_data.mtype);
      memset(data, '\0', MAX_MSG_LEN);
      memcpy(data, pre, strlen(pre));

memcpy(data+strlen(pre), php_data.mtext, strlen(php_data.mtext));
      msg_send(php_msg1, 2, data);
      
      bzero(php_data.mtext, strlen(php_data.mtext));
    }
    //break;
  }
  free(data);
}

static int msg_send(int msg_id, int fd, char *data)
{
  struct msg_st some_data;

//some_data = malloc( sizeof(struct msg_st) );

memcpy(some_data.mtext, data, strlen(data) + 1);
  some_data.mtext[strlen(data)] = '\0';
  some_data.mtype= fd;

printf("will send %s \n", &some_data.mtext);
  //int msgsnd(int msqid, const void *msgp, size_t msgsz, int msgflg); 
  if((msgsnd(msg_id,(void *) & some_data, strlen(data), 0)) == -1)      
  {
    perror("msgsnd");
    return 0;
  }

return 1;
}

转自：http://blog.csdn.net/leinchu/article/details/8141665

PHP发送邮件标题乱码的解决

[实践Ok]linux rabbitMQ 安装 CentOS rabbi

评论列表

2012-11-8 10:04 | fg4fdfg7sd

从小培养孩子过硬的心理素质情商是指非智力因素，就是人们常说的心理素质。如果一个人性格孤僻、怪异、不易合作；自卑、脆弱，不能面对挫折；急燥、自负，情绪不稳定等等，这都是情商不足的表现，即使他的智商再高也很难有所成就，所以情商是一个人获得成功的关键。情商虽有一定的先天遗传因素，但更重要是后天发展的。容颜那么如何从小培养孩子的情商呢？我公司主营建材行业，升降机,升降平台,升降机,升降平......68 zan

分页： 1/1

向东博客专注WEB应用构架之美 --- 构架之美，在于尽态极妍 | 应用之美，在于药到病除|赢在IT，Playin' with IT,Focus on Killer Application,Marketing Meets Technology.

PHP与C(或其它语言)通过消息队列进行通讯，完整代码

分类

最新日志

链接

向东博客 专注WEB应用 构架之美 --- 构架之美，在于尽态极妍 | 应用之美，在于药到病除|赢在IT，Playin' with IT,Focus on Killer Application,Marketing Meets Technology.

PHP与C(或其它语言)通过消息队列进行通讯，完整代码

分类

最新日志

链接

向东博客专注WEB应用构架之美 --- 构架之美，在于尽态极妍 | 应用之美，在于药到病除|赢在IT，Playin' with IT,Focus on Killer Application,Marketing Meets Technology.