El patrón "Observer" (Observador) - Parte IV

Esta desencadenado!!!!! El primer ataque ha sido lanzado. Cerebro ha dado las órdenes a sus tropas para dominar el mundo.

En los ejemplos anteriores hemos visto como Cerebro ha conseguido clonar cualquier robot utilizando un “Patron Prototype”, ha conseguido darles un rol dinámicamente con el “Patron Extension Objects”, y ha repartido las ordenes con un “Patron command”.

Pero como ya sabemos, Cerebro está loco, pero no es tonto. Sabe, que algo puede salir mal, que un pequeño detalle puede destruir sus planes de dominar el mundo. Pero también sabe que una retirada a tiempo es una victoria.

Por lo tanto, ha equipado a sus tropas de una radio de comunicaciones. Pero, porque ha hecho esto?. Sencillo, en el fragor de la batalla, las comunicaciones directas se hacen complicadas. Es difícil hacer llegar las ordenes, y muchas veces no se tiene claro a quien le estamos dando esas órdenes ( será a “Mazinger Z” o “El Vengador”? ). Conquistar el mundo no es fácil, de hecho muchos lo han intentado pero no lo han conseguido.

Cerebro ha estudiado con detenimiento todos los intentos anteriores para no reproducir los mismos errores que otros han cometido. Qué pasaría si para dar nuevas órdenes, necesitase que el sargento “Mazinger Z” tuviese que recorrer la trinchera indicando uno por uno a todos los robots que se retirasen?. Desde que le diese la orden al primer robot, hasta que se la diese al último, pasaría un tiempo precioso. Además, y si ocurre algo por el camino?. Las posibilidades de que las órdenes no lleguen a todos los integrantes de la tropa son amplias.

Sabiendo esto, Cerebro recurre nuevamente a su gurú “Marin Fowler” y decide hacer un cambio fácil y rápido el comportamiento de sus tropas, utilizando el “Patron Observer”.

Como Cerebro no es tonto, ha encontrado una malvada forma de enviar las órdenes a sus tropas. Los robots “Mazinger Z” y “El Vengador”, estarán equipados con una radio que sintoniza “La señal del mal”. Sus tropas estarán atentas a la radio, y cuando esta emita una canción de “Metallica” les indicara que acción deben tomar.

El código sería algo así:

package observer.paso1;<br /><br />public class Mensaje {<br /><br /> private String mensaje = "";<br /><br /> public String getMensaje() {<br /> return mensaje;<br /> }<br /><br /> public void setMensaje(String mensaje) {<br /> this.mensaje = mensaje;<br /> }<br /><br />}

package observer.paso1;<br /><br />public interface Observador {<br /><br /> public void actualizar(Mensaje informacion);<br /><br />}

package observer.paso1;<br /><br />public interface Sujeto {<br /><br /> public void addObservador(Observador obs);<br /><br /> public void removerObservador(Observador obs);<br /><br /> public void notificarObservador();<br /><br />}

package observer.paso1;<br /><br />public class MazingerZ implements Observador {<br /><br /> public MazingerZ() {<br /> System.out.println("Construyendo robot Mazinger Z");<br /> }<br /><br /> private void mostrar(String arg) {<br /> System.out.println("Mazinger Z : " + arg);<br /> }<br /><br /> public void actualizar(Mensaje mensaje) {<br /> mostrar("Actualizado");<br /> String kk = mensaje.getMensaje();<br /> mostrar("Mensaje de texto : " + kk);<br /> }<br /><br />}

package observer.paso1;<br /><br />public class ElVengador implements Observador {<br /><br /> public ElVengador() {<br /> System.out.println("Construyendo robot El Vengador");<br /> }<br /><br /> private void mostrar(String arg) {<br /> System.out.println("El Vengador : " + arg);<br /> }<br /><br /> public void actualizar(Mensaje mensaje) {<br /> mostrar("Actualizado");<br /> String kk = mensaje.getMensaje();<br /> mostrar("Mensaje de texto : " + kk);<br /> }<br /><br />}

package observer.paso1;<br /><br />import java.util.ArrayList;<br /><br />public class Cerebro implements Sujeto {<br /><br /> private ArrayList misObservadores;<br /> private Mensaje mensaje;<br /><br /> public Cerebro(){<br /> mostrar("Creando a Cerebro");<br /> misObservadores = new ArrayList();<br /> }<br /><br /> public void mostrar(String arg){<br /> System.out.println("Cerebro : "+arg);<br /> }<br /><br /> public void addObservador(Observador observador){<br /> mostrar("Anadido un nuevo Observador");<br /> misObservadores.add(observador);<br /> mostrar("Ya tengo : " + misObservadores.size() + " observadores ");<br /> }<br /><br /> public void removerObservador(Observador observador){<br /> mostrar("Eliminando un observador");<br /> misObservadores.remove(observador);<br /> mostrar("ahora me quedan : " + misObservadores.size() + " observadores ");<br /> }<br /><br /> public void notificarObservador(){<br /> mostrar("notificar observador");<br /> mensaje = new Mensaje();<br /> mensaje.setMensaje("En la nave");<br /> for( int i = 0; i < misObservadores.size(); i++ ){<br /> Observador observador = (Observador) misObservadores.get(i);<br /> observador.actualizar(mensaje);<br /> }<br /> }<br /><br />}

package observer.paso1;<br /><br />public class Test {<br /><br /> public static void main(String[] args) {<br /> Cerebro cerebro = new Cerebro();<br /> MazingerZ mazingerZ1 = new MazingerZ();<br /> ElVengador elVengador1 = new ElVengador();<br /> MazingerZ mazingerZ2 = new MazingerZ();<br /> ElVengador elVengador2 = new ElVengador();<br /> MazingerZ mazingerZ3 = new MazingerZ();<br /> ElVengador elVengador3 = new ElVengador();<br /> cerebro.addObservador(mazingerZ1);<br /> cerebro.addObservador(mazingerZ2);<br /> cerebro.addObservador(mazingerZ3);<br /> cerebro.addObservador(elVengador1);<br /> cerebro.addObservador(elVengador2);<br /> cerebro.addObservador(elVengador3);<br /> cerebro.removerObservador(mazingerZ1);<br /> cerebro.notificarObservador();<br /> }<br /><br />}

De este modo, Cerebro se puede comunicar rápidamente con todas sus tropas. Es brillante, es genial, es maravilloso, es.........perfecto?. Bueno, la verdad es que está muy bien, pero imaginemos por un momento, una situación en la que un robot consigue infiltrarse en el alto mando enemigo, y descubre que el enemigo está a punto de ser derrotado, y justo en ese momento de éxtasis, la radio emite “The Call of Ktulu" (la canción que indica a las tropas que hay que retirarse).

NOOOOOOOOO (bueno, esto está traducido, claramente, un robot diría algo así como BEP-BEP-BEP). Nuestro robot espía, tiene una información valiosísima, pero que no puede comunicar a su alto mando, porque la forma de transmisión es únicamente de tipo “Push” (desde Cerebro a sus tropas), por lo que no hay retorno.

Qué situación, el robot necesita transmitir que el ataque debe continuar pero......jajajajajajajaja, Cerebro ha pensado en ello, y ha decidido implementar un “Patron observer” que permita la transmisión tipo “Push” (del sujeto emisor a todos los sujetos receptores) y tipo “Pull” (uno de los objetos receptores, puede solicitar una información al objeto emisor para que este la envié a todos los demás). Así, nuestro robot espía, estará equipado con un número de teléfono al que podrá llamar y solicitar que emitan "Master of Puppets", y cuando esta canción sea emitida por la radio, los robots “Mazinger Z” y “El Vengador” que la escuchen, sabrán que ha llegado el momento de la ofensiva final!!!. Para ello, Cerebro deberá modificar ligeramente su código.

El primer paso será que nuestro sujeto, implementara un nuevo método que hemos añadido a la interfaz Sujeto( solicitarInformacion ), que permitirá recibir las llamadas telefónicas del robot espía. Veremos también que el constructor de los robots “Mazinger Z” y “El Vengador” también ha cambiado un poco. Ahora estos robots, almacenaran una referencia al constructor. También modificaremos el código de nuestro robot “Mazinger Z” (suponemos que este será el robot espía en el momento en que decide que pese a lo que emite la radio, hay que atacar y pide que se emita “Master of Puppets” que es otra señal de ataque ).

El código final sería algo así:

package observer.paso2;<br /><br />import observer.paso1.Mensaje;<br />import observer.paso1.Observador;<br /><br />public interface Sujeto {<br /><br /> public void addObservador(Observador obs);<br /><br /> public void removerObservador(Observador obs);<br /><br /> public void notificarObservador(Mensaje mensaje);<br /><br /> public void solicitarInformacion(String arg);<br /><br />}

package observer.paso2;<br /><br />import observer.paso1.Mensaje;<br />import observer.paso1.Observador;<br /><br />public class MazingerZ implements Observador {<br /><br /> private Sujeto cerebro;<br /><br /> public MazingerZ(Sujeto sujeto) {<br /> mostrar("creando a Mazinger Z");<br /> this.cerebro = sujeto;<br /> this.cerebro.addObservador(this);<br /> this.cerebro.solicitarInformacion("Master of Puppets");<br /> }<br /><br /> private void mostrar(String arg) {<br /> System.out.println("Mazinger Z : " + arg);<br /> }<br /><br /> public void actualizar(Mensaje mensaje) {<br /> mostrar("Actualizandome : " + mensaje.getMensaje());<br /> }<br /><br />}

package observer.paso2;<br /><br />import observer.paso1.Mensaje;<br />import observer.paso1.Observador;<br /><br />public class ElVengador implements Observador {<br /><br /> public ElVengador(){<br /> mostrar("creando a El Vengador");<br /> }<br /><br /> private void mostrar(String arg) {<br /> System.out.println("El Vengador : " + arg);<br /> }<br /><br /> public void actualizar(Mensaje mensaje) {<br /> mostrar("Actualizandome : " + mensaje.getMensaje());<br /> }<br /><br />}

package observer.paso2;<br /><br />import java.util.ArrayList;<br /><br />import observer.paso1.Mensaje;<br />import observer.paso1.Observador;<br /><br />public class Cerebro implements Sujeto{<br /><br /> private ArrayList misObservadores;<br /><br /> public Cerebro(){<br /> mostrar("Creando un nuevo Cerebro");<br /> misObservadores = new ArrayList();<br /> }<br /><br /> public void mostrar(String arg){<br /> System.out.println("Cerebro : "+arg);<br /> }<br /><br /> public void addObservador(Observador obs){<br /> mostrar("Anadido un nuevo observador");<br /> misObservadores.add(obs);<br /> mostrar("Ya tengo : " + misObservadores.size() + " observadores ");<br /> }<br /><br /> public void removerObservador(Observador obs){<br /> mostrar("Eliminando observador");<br /> misObservadores.remove(misObservadores.indexOf(obs));<br /> mostrar("ahora me quedan : " + misObservadores.size() + " observadores ");<br /> }<br /><br /> public void notificarObservador(Mensaje msg ){<br /> mostrar("notificar observadores");<br /> for( int i = 0; i < misObservadores.size(); i++ ){<br /> Observador obs = (Observador) misObservadores.get(i);<br /> obs.actualizar(msg);<br /> }<br /> }<br /><br /> public void solicitarInformacion(String arg){<br /> mostrar("recibiendo una peticion");<br /> Mensaje mensaje = new Mensaje();<br /> mensaje.setMensaje(arg);<br /> this.notificarObservador(mensaje);<br /> }<br /><br />}

package observer.paso2;<br /><br />public class Test {<br /><br /> public static void main(String[] args) {<br /> Cerebro dispar = new Cerebro();<br /> MazingerZ mazingerZ = new MazingerZ(dispar);<br /> }<br /><br />}

Evidentemente, Cerebro que ha estudiado la API de JAVA y sabe que existe la clase java.util.Observable y la interface java.util.Observer. La primera no la ha utilizado, pues eso implicaría que Cerebro extienda o herede de “Observable”. Esto podría ser posible, pero en realidad Cerebro extiende de una larga extirpe de profesores diabólicos empeñados en conquistar el mundo, y ni quiere ni puede extender de Observable. ( class Cerebro extends ExtirpeDeProfesoresDiabolicos, Observable --> esto no es posible ). Por eso ha decidido construirse su propia interface “Sujeto”.

Con respecto a la interface java.util.Observer, si la podría haber utilizado para que sus robots “Mazinger Z” y “El Vengador” la implementasen en lugar de implementar “Observador”, pero ya saben, los genios del mal les gusta hacer las cosas a su manera.

Esta historia continuara……

PARTE 5