Quiero configurar una aplicación de integración de muelles de modo que si pongo una cantidad de tareas, cada una representada por un mensaje, en un canal, luego uno de un grupo de puntos finales seleccionará la siguiente tarea y la procesará. Esto supondría un poco de servicio de ejecutor de grupo de subprocesos, supongo.Compitiendo Consumidores
5
A
Respuesta
6
Sí, use un dispatcher + task executor con el canal (aka ExecutorChannel). De esta forma, cualquier punto final (por ejemplo, service-activator
) que consuma desde el canal se invocará de forma asíncrona utilizando el grupo de subprocesos del asignador.
En el siguiente ejemplo, cualquier mensaje que aterrice en el canal channel01
será consumido por el servicio jobLauncher
dentro de uno de los hilos taskExecutor
.
<int:channel id="channel01">
<int:dispatcher task-executor="taskExecutor">
</int:channel>
<task:executor id="taskExecutor" pool-size="2"/>
<int:service-activator input-channel="channel01" ref="jobLauncher">
Cuestiones relacionadas
- 1. Query Free Queue - Productor único, múltiples consumidores
- 2. TThreadedQueue no es capaz de múltiples consumidores?
- 3. Múltiples consumidores y consultar un C# BlockingCollection
- 4. Los consumidores de mensajes de RabbitMQ dejan de consumir mensajes
- 5. Java: ¿LinkedBlockingQueue tiene en cuenta el orden de los consumidores?
- 6. Múltiples consumidores para una sola cola en MassTransit
- 7. TPL flujos de datos múltiples linkto consumidores no trabajan
- 8. Procesamiento concurrente de InputStream individual con consumidores independientes
- 9. Consumidores en competencia en tránsito masivo con RabbitMQ
- 10. ¿El productor trabaja sistemáticamente con hash para los consumidores a través de una cola de mensajes?
- 11. ¿Cómo puedo implementar un paradigma de múltiples productores y consumidores múltiples en Gevent?
- 12. JBoss HornetQ: establecer el tamaño de la ventana del consumidor para consumidores lentos
- 13. ActiveMQ obtener el número de consumidores que escuchan un tema de java
- 14. JMS: ¿Cómo funcionan los selectores de mensajes con múltiples consumidores de cola y tema?
- 15. ¿Cómo utilizo una colección de bloqueo en el patrón Productor/Consumidor cuando los productores también son consumidores? ¿Cómo termino?
- 16. C++ Concursos de programación
- 17. ¿Cuál es el buen punto de partida para el desarrollo de Clojure en Google App Engine
- 18. ¿Es posible usar extensiones PECL en HipHop?
- 19. ¿Cómo implementar una solución de consumidor competidora?
- 20. Sitecore y ASP.net MVC
- 21. La mejor manera de distribuir tareas teniendo en cuenta la latencia y la eficacia
- 22. Consumidor de ActiveMQ se bloquea
- 23. Genérico .Net Productor/Consumidor
- 24. Algoritmo de resolución de puntos y cajas
- 25. ¿Hay alguna cola de bloqueo de la feria (ilimitada) en java?
- 26. Mejor método de autenticación para otorgar acceso API a la aplicación Rails
- 27. ¿Qué es más rápido: entrada de datos adecuada o estructura de datos adecuada?
- 28. Bloqueos y mensajes de recuperación de lotes con RabbitMq
- 29. Extracción de selección de N + 1 sin .include
- 30. ¿Es esto una mala práctica sobrecargar un método?