Python: Может ли ZeroMQ настроить обратный вызов для вызова после получения сообщения? - PullRequest
Новая
       8

Python: Может ли ZeroMQ настроить обратный вызов для вызова после получения сообщения?

0 голосов
/ 26 июня 2018

Я новый ученик ZeroMQ. Я хочу знать, существует ли подход для установки обратного вызова, который может быть вызван, когда приходит сообщение, я имею в виду, когда данные существуют в потоке.

Я не хочу использовать поток и цикл для указания данных, а затем вызывать обратный вызов.

У вас есть идеи, как решить этот вопрос?

1 Ответ

0 голосов
/ 26 июня 2018

Ну, нативный API ZeroMQ начиная с v2.x до недавнего v4.2 + никогда не использовал обратный вызов, связанный с низкоуровневыми внутренностями. Все службы API были разработаны таким образом, чтобы реагировать на методы .poll( 0 ) или .recv( zmq.NOBLOCK ) и позволять пользовательскому приложению решать и действовать соответствующим образом.

Если действительно необходимо использовать аппаратные обратные вызовы, есть два возможных направления:

1) использовать общий инструмент python - фабрику Tkinter.mainloop(), где можно настроить обработчик блокировки с экземпляром StringVar(), устанавливается .recv() следующим образом (здесь, к счастью, способ блокировки): aStringVAR.set( aSocket.recv() ), с которым также связан Tracer, который вызывает требуемый обработчик обратного вызова в ответ на получение StringVar нового значения сохраняется. 

>>> #-----------------------------------------------FAST MOCK-UP EXAMPLE
>>> import Tkinter as tk                          # python27
>>> root = tk.Tk()
>>> root.protocol( "WM_DELETE_WINDOW", root.quit() )
'3071841620Ldestroy'
>>> #------VAR-------------------------------------IMPORTANT TOOL:
>>> aStringVAR = tk.StringVar()
>>> aStringVAR.set( "_init_" )

>>> def aKeyPressEventHANDLER( anEvent ): # SIMPLE EventHANDLER,
        #                                 #        also ignites remote responsive processes
...     aTemplate = "[KEY]::{3: >10s}\n<s/n>::{0: >10d}\n(=@=)::{1: > 10d}\n^from::({5:})"
...     sString   = aTemplate.format( anEvent.serial,
...                                   anEvent.time,
...                                   anEvent.char,
...                                   anEvent.keysym,
...                                   anEvent.keysym_num,
...                               str(anEvent.widget )
...                               )
...     aStringVAR.set( sString ) # <----------------- emulated instead of  aSocket.recv()
...     print sString
... 
>>> #----VAR_TRACER----------------------------------------[#1]
>>> def aVAR_TRACER_A( p1_quasiNAME, p2_indexOrEmptyString, p3_accessMODE ):
...     print "aVAR_TRACER_A()-called::(on){0:} traced_event({1:})".format( str( p1_quasiNAME ), str( p3_accessMODE ) )
...     # ###############=[A]#######
...     # < do some task =[A] here >
...     # ###############=[A]#######
...     print "aVAR_TRACER_A()         [{0:}]".format(   str( root.globalgetvar( p1_quasiNAME ) ).replace( " ", "" ) )
...
>>> #-----VAR_A_tracer_ID------------------------------"w" EVENT SNIFFER WAITING FOR ASSIGNMENT INTO aStringVAR
>>> aTraceVAR_A_tracer_ID = aStringVAR.trace_variable( "w", aVAR_TRACER_A )

aVAR_TRACER_A()-called::(on)PY_VAR0 traced_event(w)
aVAR_TRACER_A()         [[KEY]::a<s/n>::832(=@=)::88486992^from::(.)]
[KEY]::         a
<s/n>::       832
(=@=)::  88486992
^from::(.)
aVAR_TRACER_A()-called::(on)PY_VAR0 traced_event(w)
aVAR_TRACER_A()         [[KEY]::KP_6<s/n>::832(=@=)::88509107^from::(.)]
[KEY]::      KP_6
<s/n>::       832
(=@=)::  88509107
^from::(.)
aVAR_TRACER_A()-called::(on)PY_VAR0 traced_event(w)
aVAR_TRACER_A()         [[KEY]::KP_Multiply<s/n>::832(=@=)::88541180^from::(.)]
[KEY]::KP_Multiply
<s/n>::       832
(=@=)::  88541180
^from::(.)

или более сложный, если используются виртуальные события Tkinter с прямым вводом: 

################################################ SETUP EVENT-ROUTING Injector

self.aSigFromZMQ = "<<aVirtualEventSignalledFromZMQ_LAYER>>"

self.bind( self.aSigFromZMQ, anEventHANDLER )
#   |
#   .bind <<virtual_EventNAME>> altogether with <anEventHANDLER>-call


################################################ Context-fully TRIGGER Injector

self.event_generate( self.aSigFromZMQ, aSigContextDICT )
#   |
#   .event_generate( <eventNameId>, **args )  #   triggers <eventNameId>
#                                             # + passes **args, that allows
#                                             #          to set <keyword>=<value> pairs for Event-fields,
#                                             #          that are passed to anEventHANDLER via <Event>-object .

2) изменить ZeroMQ и использовать скорее , соответственно. новый API NNG, в котором механизмы обратного вызова могут быть связаны с состоянием / событиями сокетов.

...