자바가있는 akka websocket, 클라이언트 수 계산, 클라이언트에 메시지 보내기

나는 websocket 서버를 만들기 위해 akka java websocket 자습서를 따르고 있습니다. 두 가지 추가 기능을 구현하고 싶습니다.

• 연결된 클라이언트의 수를 표시 할 수 있지만 동시에 연결된 클라이언트가 100 개라는 것을 알고 있어도 결과는 항상 0 또는 1입니다.
• Websocket 통신은 양방향입니다. 현재 서버는 클라이언트가 메시지를 보낼 때만 메시지로 응답합니다. 서버에서 클라이언트로 메시지 보내기를 시작하려면 어떻게해야합니까?

다음은 내 클라이언트 계산 구현을 최소한으로 수정 한 원본 akka Java 서버 예제 코드입니다.

public class websocketServer {
private static AtomicInteger connections = new AtomicInteger(0);//connected clients count.

public static class MyTimerTask extends TimerTask {
//called every second to display number of connected clients.
    @Override
    public void run() {
        System.out.println("Conncurrent connections: " + connections);
    }
}


//#websocket-handling
  public static HttpResponse handleRequest(HttpRequest request) {
      HttpResponse result;
      connections.incrementAndGet();
      if (request.getUri().path().equals("/greeter")) {
          final Flow<Message, Message, NotUsed> greeterFlow = greeter();
          result = WebSocket.handleWebSocketRequestWith(request, greeterFlow);
      } else {
          result = HttpResponse.create().withStatus(413); 
      }
      connections.decrementAndGet();
      return result;
  }


public static void main(String[] args) throws Exception {
    ActorSystem system = ActorSystem.create();
    TimerTask timerTask = new MyTimerTask();
    Timer timer = new Timer(true);
    timer.scheduleAtFixedRate(timerTask, 0, 1000);
    try {
      final Materializer materializer = ActorMaterializer.create(system);

      final Function<HttpRequest, HttpResponse> handler = request -> handleRequest(request);
      CompletionStage<ServerBinding> serverBindingFuture =
        Http.get(system).bindAndHandleSync(
          handler, ConnectHttp.toHost("****", 1183), materializer);


      // will throw if binding fails
      serverBindingFuture.toCompletableFuture().get(1, TimeUnit.SECONDS);
      System.out.println("Press ENTER to stop.");
      new BufferedReader(new InputStreamReader(System.in)).readLine();
      timer.cancel();
    } catch (Exception e){
        e.printStackTrace();
    }
    finally {
      system.terminate();
    }
  }

  //#websocket-handler

  /**
   * A handler that treats incoming messages as a name,
   * and responds with a greeting to that name
   */
  public static Flow<Message, Message, NotUsed> greeter() {
    return
      Flow.<Message>create()
        .collect(new JavaPartialFunction<Message, Message>() {
              @Override
              public Message apply(Message msg, boolean isCheck) throws Exception {
                if (isCheck) {
                    if (msg.isText()) {
                        return null;
                    } else {
                        throw noMatch();
                    }
                } else {
                    return handleTextMessage(msg.asTextMessage());
                }
              }
        });
  }

  public static TextMessage handleTextMessage(TextMessage msg) {
    if (msg.isStrict()) // optimization that directly creates a simple response...
    {
        return TextMessage.create("Hello " + msg.getStrictText());
    } else // ... this would suffice to handle all text messages in a streaming fashion
    {
        return TextMessage.create(Source.single("Hello ").concat(msg.getStreamedText()));
    }
  }
  //#websocket-handler
}