- <?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);
- }
- }
- <?php
- define('base_path' , dirname(__FILE__));//msg_write.php
- include(base_path.'/msg.php');
- $msg = new msg(1, false);
- $msg1 = new msg(2, false);
- if($argv[1]=='del') $msg->remove();
-
-
- $str = 'There are no user contributed notes for this page.';
- while(1){
- $data = substr($str,0,rand(18,25));
- $msg->send(rand().$data, rand(1,10));
- echo $data." -> sent\n";
- echo 'Get:'.$msg1->receive(false, 0).chr(10);
- sleep(3);
- //usleep(10000);
- }
- echo 'Done';
C, gcc -g -o m msg.c -lpthread;
- #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];
- };
- void logst(struct msg_st some_data);
- 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));
- int msg_to_recevie = 0;
- char* data;
- data = malloc(MAX_MSG_LEN);
- char *pre = "You told me:";
- while(running){
- if(msgrcv(php_msg,(void *) &php_data, MAX_MSG_LEN, msg_to_recevie , 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, msg_to_recevie= %d;\n", php_data.mtext, php_data.mtype,msg_to_recevie);
- 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);
- if((msgsnd(msg_id,(void *) some_data, MAX_MSG_LEN,0)) == -1)
- {
- perror("msgsnd");
- return 0;
- }
- return 1;
- }
- void logst(struct msg_st some_data)
- {
- FILE *fp;
- fp = fopen("file.dat", "w+");
- if (!fp)
- {
- printf("open file error!");
- return;
- }
- fwrite(&some_data, sizeof(struct msg_st), 1, fp);
- fclose(fp);
- }
運(yùn)行：./m