CarpinchoMQ

Tabla de Contenido

1. Sobre el Proyecto
   • Tecnologias
2. Empezando
   • Prerequisitos
   • Uso
   • Docker
3. Licencia
4. Fuentes
5. Agradecimientos

Acerca del Proyecto

Carpincho MQ surge de la necesidad de reflejar los conceptos estudiados en la materia Arquitecturas Concurrentes de la Facultad Tecnologica Nacional Argentina (UTN)

Para ello se desarrollo una solucion software de administracion de colas de mensajes distribuida, con dos modos de trabajo:

• Cola de trabajo: el mensaje sera entregado unicamente a uno de los consumidores disponibles suscriptos a la cola (elegido de forma round-robin).
• Publicar-suscribir: El mensaje sera entregado a todos los consumidores disponibles suscriptos

Por otro lado, los receptores de la cola de mensajes podrán optar por dos modalidades de consumo:

• Consumo no Transaccional: CarpinchoMQ coinsidera que fue un consumo exitoso del mensaje sin esperar la confirmacion por parte del receptor que lo proceso completo (se envia el ACK al principio del procesamiento del mensaje)

• Consumo transaccional: CarpinchoMQ coinsidera que fue un consumo exitoso del mensaje tras la confirmacion por parte del receptor que lo proceso completo (se envia el ACK luego de haber completado el procesamiento del mensaje).

Si el receptor no envia la confirmacion en determinado tiempo, por timeout se coinsidera que el consumo fallo.

En este caso Carpincho hara lo siguiente:

• Si Carpi trabaja en modo "cola de trabajo", se lo enviara a otro consumidor.
• Si Carpi trabaja en modo "Publicar-Suscribir", se reencola hasta que el consumidor lo adquiera.

(back to top)

Tecnologias

CarpinchoMQ nacio gracias a:

• elixir.ex

• horde

• Node.js

• React.js

(back to top)

Empezando

Prerequisitos

Debemos tener instalado:

• Visual Studio Code (recomendacion para levantar el proyecto).
• Elixir
• Ejecutar el comando deps.get para obtener las dependencias del proyecto:

mix deps.get

Uso

Para utilizar CarpinchoMQ debes levantar lineas de comando. A continuacion te pasamos los comandos:

• Levantar un nodo nuevo en una consola (para tirarlo abajo Ctrl+C):

  iex --sname <nombre_nodo> --cookie <nombre_cookie> -S mix run ./lib/app.ex <puertohttp> <puertoudp>

  iex --sname a --cookie cookie -S mix run ./lib/app.ex 3333 8000

• Crear una cola nueva:

  Producer.new_queue <nombre_cola>, <tamaño_maximo>, <modo_de_trabajo>, <modo_de_transaccionalidad>

  Ejemplo:

  Producer.new_queue :cola1, 23, PubSub, :transactional

• Pushear un mensaje a la cola:

  Producer.push_message <nombre_cola>, <mensaje>

• Crear un Consumidor:
  • Un consumidor esta definido por un direccion y un puerto udp al que esta escuchando
  • consumer = %{address: <direccion>, port: <puerto>}
• Suscribir un consumidor a una cola:

  Consumer.subscribe <nombre_cola>, consumer

• Desuscribir un consumidor de una cola:

  Consumer.unsubscribe <nombre_cola>, consumer

• Ver el estado de una cola:

  Queue.state <nombre_cola>

• Ver si una cola está viva:

  Queue.alive? <nombre_cola>

(back to top)

Docker

4 Contenedores:

• Nodo A: puerto 3333-8000 para que pueda acceder el front
• Nodo B: puerto 4000-8001
• Nodo C: puerto 4001-8002
• Front: puerto 3000 http://localhost:3000/

Prerequisitos:

• Tener instalado docker en tu pc.

• Tener la imagen generada de carpinchomq. Si no la tenes generada, en este proyecto (estando parado en el path principal):

  docker build -t carpincho-mq-image ./

• Tener la imagen generada de carpinchomq-front. Si no la tenes generada, en el proyecto de carpincho-mq-frontend (estando parado en el path principal):

  docker build -t carpincho-mq-front-image ./

  Una vez generada las imagenes, estando parado en la raiz del proyecto:

  docker-compose up

  (back to top)

Contributing

Ayudanos a crecer con tu codigo siguiendo los siguientes pasos

1. Fork del proyecto
2. Creacion de tu Branch (git checkout -b feature/AmazingFeature)
3. Commit de tus cambios (git commit -m 'Add some AmazingFeature')
4. Push a tu branch (git push origin feature/AmazingFeature)
5. Abrir Pull Request

(back to top)

Licencia

Distributed under the UTN License. See LICENSE.txt for more information.

(back to top)

Agradecimientos

Agradecemos a los profesores y ayudantes de la materia "Implementación de Arquitecturas de Software Concurrentes"

• Ernesto Bossi
• Agustin
• Erwin Debusschere
• NicoR

(back to top)