IPC :: Pubsub.
التحميل الان

IPC :: Pubsub. الترتيب والملخص

IPC :: Pubsub. العلامات

الوحدة النمطية بيرل ينشر interpracess. الانبشرة نشر القنوات

IPC :: Pubsub. وصف

IPC :: PUBSUB هو الوحدة النمطية للبريق لقنوات النشر / الإشباع. IPC :: PUBSUB هو الوحدة النمطية لل perl for Interprocess Channels Channels.syopsis # حافلة رسائل جديدة مع DBM :: الخلفية العميقة # (أخرى محتملة تراجعت الذخيرة والجزيز) My $ Bus = IPC :: PUBSUB-> NEW (DBM_DEEP => '/tmp/pubsub.db')؛ # قناة هي أي سلسلة تعسفية بلدي قناة بلدي = '# perl6'؛ # تسجيل ناشر جديد (يمكنك النشر إلى قنوات متعددة) بلدي PUB = $ Bus-> New_Publisher ("# PERL6"، "#Moose")؛ # نشر رسالة (قد يكون كائن معقد) لهذه القنوات $ PUB-> MSG ("هذه رسالة")؛ # سجل مشتركا جديدا (يمكنك الاشتراك في قنوات متعددة) لي SUB = $ Bus-> New_subscriber ("# Moose")؛ # نشر كائن للقنوات $ PUB-> MSG ("هذه رسالة أخرى")؛ # قم بتعيين جميع الرسائل اللاحقة من هذا الناشر تنتهي في 30 ثانية $ PUB-> انتهاء الصلاحية (30)؛ $ pub-> msg ("هذه الرسالة سوف تذهب بعيدا في 30 ثانية")؛ # بسيطة الحصول على: إرجاع الرسائل المرسلة منذ الحصول على السابق، # ولكن فقط للقناة الأولى. بلدي stmgs = $ sub-> الحصول عليها؛ # الحصول على بسيطة، مع مفتاح القناة الصريحة (يجب أن يكون من بين تلك التي تم الاشتراك فيها في البداية) بلدي moose_msgs = $ sub-> get ("# moose")؛ # احصل على مجمع: إرجاع مرجع تجزئة من القنوات إلى صفيف # مراجع . بلدي $ hash_ref = $ sub-all؛ # تغيير قائمة القنوات التي نشترك فيها إلى $ الفرعية> الاشتراك ('بعض القناة الأخرى')؛ $ sub-> إلغاء الاشتراك ("بعض القناة الأخرى")؛ # تغيير قائمة القنوات التي ننشرها إلى $ PUB-> نشر ("بعض القناة الأخرى")؛ $ pub-> unpublish ("بعض القناة الأخرى")؛ # الإدراج والتحقق مما إذا كنا في قناة بلدي sub_channels = $ subs-> القنوات؛ بلدي pub_channels = $ pub-> القنوات؛ طباعة "SUB IN في #Moose" إذا كانت القنوات الفرعية $->> {'# Moose'}؛ طباعة "حانة في #Moose" إذا كانت $ pub-> القنوات -> {'# moose'}؛ # APIs التلاعب ذاكرة التخزين المؤقت الخام (لا ينصح؛ استخدام -> تعديل بدلا من ذلك) $ Bus-> قفل ('قناة')؛ حافلة $ -> فتح ('القناة')؛ MyTimed_Msgs = $ Bus-> Fetch ('key1'، 'key2'، 'key3')؛ $ Bus-> Store ('مفتاح'، 'القيمة'، الوقت، 30)؛ # تحديث الذرية لمحتوى ذاكرة التخزين المؤقت؛ يتم تخزين $ _ مرة أخرى على نهاية رد الاتصال. My $ RV = $ Bus-> تعديل ('KEY' => SUB {DELETE $ _-> {foo}})؛ # الاختصار مقابل الحافلات $> تعديل ('المفتاح' => sub {$ _ = 'val'})؛ $ bus-> تعديل ('مفتاح' => 'val')؛ # الاختصار مقابل الحافلات $> تعديل ('مفتاح' => sub {$ _})؛ $ Bus-> تعديل ('المفتاح')؛ توفر هذه الوحدة تطبيقات برمجة تطبيقات بسيطة لنشر الرسائل إلى القنوات وللاشتراك لدىهم. عند نشر الرسالة على قناة، سيحصل جميع المشتركين الموجودين حاليا في هذه القناة على الحصول عليها المقبل أو get_all call.clystrenty، فهو يوفر ثلاثة عقود: DBM_DEEP لتخزين على القرص على القرص، والذين لتخزين متعدد المضيفين المحتمل، والجزيز تخزين عملية واحدة. يرجى الاطلاع على الاختبارات في T / لهذا التوزيع، وكذلك "ملخص "أعلاه، لبعض أمثلة الاستخدام؛ وثائق مفصلة غير متوفرة بعد. متطلبات: perl.

IPC :: Pubsub. برامج ذات صلة