2012-06-02 10 views
13

Ich habe Client und Server in PHP über Shared Memory kommunizieren, jetzt möchte ich auf dieses Shred Speicherobjekt mit Boost.Interprocess zugreifen, wie kann ich darauf zugreifen? server.php:Wie kommuniziert man zwischen PHP und Boost Library IPC?

function create_image($str){ 
    // Create a blank image and add some text 
    $im = imagecreatetruecolor(300, 20); 
    $text_color = imagecolorallocate($im, 233, 14, 91); 
    $stringBanner=exec("date").$str; 
    imagestring($im, 1, 5, 5, $stringBanner , $text_color); 

    ob_start(); 
    imagejpeg($im); 
    $i = ob_get_contents(); 
    ob_get_clean(); 
    imagedestroy($im); 
    return $i; 
    } 
    echo "\n".__FILE__."\n"; 
    $shm_key = ftok(__FILE__, 't'); 
    echo $shm_key."\n"; 


    $shm_id = shmop_open($shm_key, "a", 0, 0); 
if ($shm_id) { 
    //it is already created 
    shmop_delete($shm_id); 
    shmop_close($shm_id); 
} 
//you need to create it with shmop_open using "c" only 
echo "try to create\n"; 
if(!$shm_id = shmop_open($shm_key, "c", 0777, 1024*4))exit(-1); 


echo "ID ".$shm_id."\n"; 
$i=0; 
for(;;){ 
sleep(1); 
$s="i=".$i++; 
$str=$i; 
$im=serialize(create_image($str)); 

$data=serialize(strlen($im)); 
$shm_bytes_written = shmop_write($shm_id, $data, 0); 
$shm_bytes_written = shmop_write($shm_id, $im, 32); 
echo $shm_bytes_written." bytes is written: ".$s." ID = $shm_id\n"; 
} 

client.php

<?php 
$shm_key =1946222626;// ftok(__FILE__, 't'); 
$shm_id = shmop_open(
     $shm_key, "a", 
     0644,1024*4 
     ); 


$s=shmop_size($shm_id); 
$data = unserialize(
     shmop_read($shm_id, 0, 
      31) 
     ); 

$im = unserialize(
     shmop_read($shm_id, 32, 
       $data) 
     ); 
    // Set the content type header - in this case image/jpeg 
header('Content-Type: image/jpeg'); 
// Output the image 
echo $im; 

welche Art von Schlüssel sollte ich Erhöhung bereitstellen, um diesen Speicherbereich zu bekommen?

boost_client.cpp

#include <boost/interprocess/shared_memory_object.hpp> 
#include <iostream> 
#include "sys/msg.h" 

int main() 
{ 
    int msqid; 
    key_t key; 
    char f[]="??????"; 
    int mid; 

    //key = ftok(, 't'); 
    //msqid = msgget(key, 0666 | IPC_CREAT); 

    std::cout<<msqid<<std::endl; 
    boost::interprocess::shared_memory_object 
    shdmem(boost::interprocess::open_or_create, 
      f,//"shmem_server", 
      boost::interprocess::read_write); 
    shdmem.truncate(1024); 
    std::cout << shdmem.get_name() << std::endl; 
    boost::interprocess::offset_t size; 
    if (shdmem.get_size(size)) 
    std::cout << size << std::endl; 
} 

EDIT:

Nun ich die Lösung in Boost-IPC-Bibliothek Dokumente gefunden:

XSI_KEY based example from boost Docs

+0

Die PHP-Erweiterung verwendet * System V IPC-Schlüssel * s, also welche boost verwenden Sie? – hakre

+0

Ja sicher, aber es ist so versteckt hinter der Szene. – Arman

+0

Was meinst du mit "versteckt hinter der Szene"? – hakre

Antwort

1

Ich bin kein Experte in was Du machst das, aber nach dem, was ich in deiner Frage und meinem Wissen gelesen habe, würde ich dieses reine IPC-Ding fallen lassen p in ZMQ (Sie finden Wrapper in jeder Sprache, die Sie brauchen). Es soll diese Art von Problemen lösen und eine einzige API bereitstellen, die über IPC oder einen allgemeineren TCP-Socket laufen kann.