Arquiteturas
de Sistemas

// ServidorEcho.java — Lado servidor
import java.net.*;
import java.io.*;

public class ServidorEcho {
  public static void main(String[] args) throws Exception {
    // 1. Cria socket de escuta na porta 9090
    ServerSocket servidor = new ServerSocket(9090);
    System.out.println("Servidor aguardando na porta 9090...");

    while (true) {
      // 2. Bloqueia até um cliente conectar
      Socket cliente = servidor.accept();
      System.out.println("Cliente conectado: "
          + cliente.getInetAddress());

      // 3. Lê requisição e envia resposta
      BufferedReader entrada = new BufferedReader(
          new InputStreamReader(cliente.getInputStream()));
      PrintWriter saida = new PrintWriter(
          cliente.getOutputStream(), true);

      String msg = entrada.readLine();
      saida.println(msg.toUpperCase()); // processa e responde
      cliente.close();
    }
  }
}

// ClienteEcho.java — Lado cliente
import java.net.*;
import java.io.*;

public class ClienteEcho {
  public static void main(String[] args) throws Exception {
    // 1. Conecta ao servidor
    Socket socket = new Socket("localhost", 9090);

    PrintWriter saida = new PrintWriter(
        socket.getOutputStream(), true);
    BufferedReader entrada = new BufferedReader(
        new InputStreamReader(socket.getInputStream()));

    // 2. Envia requisição
    saida.println("sistemas distribuídos");

    // 3. Aguarda e exibe resposta
    String resposta = entrada.readLine();
    System.out.println("Resposta do servidor: " + resposta);
    // → SISTEMAS DISTRIBUÍDOS

    socket.close();
  }
}

import java.util.*;

// Representa o "barramento de eventos" (Fig. 2.2a)
public class BusDeEventos {
  // Mapa: tipo de evento → lista de assinantes
  private Map<String, List<Assinante>> assinantes =
      new HashMap<>();

  public void subscrever(String evento, Assinante a) {
    assinantes.computeIfAbsent(evento,
        k -> new ArrayList<>()).add(a);
  }

  public void publicar(String evento, String dados) {
    List<Assinante> lista =
        assinantes.getOrDefault(evento, List.of());
    // Middleware notifica APENAS os subscritos
    for (Assinante a : lista)
      a.notificar(evento, dados);
  }
}

// Interface do componente assinante
interface Assinante {
  void notificar(String evento, String dados);
}

public class DemoEventos {
  public static void main(String[] args) {
    BusDeEventos bus = new BusDeEventos();

    // Componente A subscreve "PEDIDO_CRIADO"
    bus.subscrever("PEDIDO_CRIADO", (ev, d) ->
        System.out.println("[Estoque] processando: " + d));

    // Componente B também subscreve o mesmo evento
    bus.subscrever("PEDIDO_CRIADO", (ev, d) ->
        System.out.println("[Pagamento] cobrando: " + d));

    // Produtor publica — não conhece os assinantes!
    bus.publicar("PEDIDO_CRIADO", "Pizza#42");

    /* Saída:
       [Estoque] processando: Pizza#42
       [Pagamento] cobrando: Pizza#42   */
  }
}