disruptor pattern - validacion - ¿Cómo se debe usar Disruptor(Patrón de Disruptor) para construir sistemas de mensajes del mundo real?
validar formulario php antes enviar (3)
Hay una biblioteca llamada Javolution (http://javolution.org/) que le permite definir los objetos como estructuras con campos de longitud fija como la cadena [40], etc., que se basan internamente en buffers de bytes en lugar de objetos de tamaño variable ... eso permite que el token ring se inicialice con objetos de tamaño fijo y, por lo tanto, (con suerte) bloques contiguos de memoria que permitan que el caché funcione de manera más eficiente.
Lo estamos usando para pasar eventos / mensajes y usar cadenas estándar, etc. para nuestra lógica empresarial.
Como el RingBuffer por adelantado asigna objetos de un tipo determinado, ¿cómo puede usar un solo búfer de anillo para procesar mensajes de varios tipos diferentes?
No puede crear nuevas instancias de objetos para insertar en el ringBuffer y eso anularía el propósito de la asignación inicial.
Entonces, podrías tener 3 mensajes en un patrón de mensajería asíncrona:
- NewOrderRequest
- NewOrderCreated
- NewOrderRejected
Entonces, mi pregunta es: ¿cómo se pretende utilizar el patrón de Disruptor para sistemas de mensajería del mundo real?
Gracias
Enlaces: http://code.google.com/p/disruptor-net/wiki/CodeExamples
Un enfoque (nuestro patrón más común) es almacenar el mensaje en su forma ordenada, es decir, como una matriz de bytes. Para las solicitudes entrantes, por ejemplo, los mensajes Fix, los mensajes binarios, se extraen rápidamente de la red y se colocan en el búfer de anillo. Los procesadores de eventos (Consumidores) se encargan de la eliminación y despacho de diferentes tipos de mensajes en ese búfer de anillo. Para las solicitudes de salida, el mensaje se serializa en la matriz de bytes preasignada que forma la entrada en el búfer de anillo.
Si está utilizando una matriz de bytes de tamaño fijo como la entrada preasignada, se requiere alguna lógica adicional para manejar el desbordamiento de mensajes más grandes. Es decir, elija un tamaño predeterminado razonable y si se excede, asigne una matriz temporal que sea más grande. Luego, deséchelo cuando la entrada se reutilice o consuma (dependiendo de su caso de uso) volviendo a la matriz de bytes preasignada original.
Si tiene diferentes consumidores para diferentes tipos de mensajes, podría identificar rápidamente si su consumidor está interesado en el mensaje específico, ya sea conociendo un desplazamiento en la matriz de bytes que transporta la información de tipo o pasando un valor discriminador a través de la entrada.
Además, no hay ninguna regla que prohíba crear instancias de objetos y pasar referencias (también lo hacemos en un par de lugares). Si pierde los beneficios de la preasignación de objetos, sin embargo, uno de los objetivos de diseño del disruptor fue permitirle al usuario elegir la forma de almacenamiento más adecuada.
Volver a las agrupaciones de objetos.
La siguiente es una hipótesis.
Si tiene 3 tipos de mensajes (A, B, C), puede hacer 3 arreglos de los asignados previamente. Eso creará 3 zonas de memoria A, B, C.
No es que solo haya una línea de caché, hay muchas y no tienen que ser contiguas. Algunas líneas de caché se referirán a algo en la zona A, otra B y otra C.
Por lo tanto, la entrada del búfer de anillo puede tener 1 referencia a un ancestro o interfaz común de A y B y C.
El problema es seleccionar la instancia en las agrupaciones; lo más simple es tener la misma longitud de matriz que la longitud del búfer de anillo. Esto implica una gran cantidad de objetos agrupados desperdiciados, ya que solo uno de los 3 se usa alguna vez en cualquier entrada, por ejemplo, la entrada de búfer de anillo 1234 podría estar usando el mensaje B [1234] pero A [1234] y C [1234] no se usan y no se pueden usar Por cualquiera.
También puede hacer una súper entrada con todas las instancias de 3 A + B + C en línea e indicar el tipo con algún byte o enumeración. Es un desperdicio en el tamaño de la memoria, pero se ve un poco peor debido a la gordura de la entrada. Por ejemplo, un lector que solo trabaje en mensajes C tendrá menos localidad de caché.
Espero no estar tan equivocado con esta hipótesis.