Netty - Jak przekazać informacje pomiędzy obsługą w tym samym rurociągu

Question

chciałbym stworzyć rurociągu koparki, takich jak:

public ChannelPipeline getPipeline() throws Exception 
{ 
    return Channels.pipeline(
      new ObjectEncoder(), 
      new ObjectDecoder(), 
      new AuthenticationServerHandler(), 
      new BusinessLogicServerHandler()); 
} 

Kluczem tutaj jest to, że chciałbym się AuthenticationServerHandler, aby móc przejść dane logowania do BusinessLogicServerHandler.

Rozumiem, że można użyć wartości Attachment, jednak tylko przechowuje informacje dla tego modułu obsługi, inne moduły znajdujące się w potoku nie mogą uzyskać do niego dostępu. Zauważyłem też, że jest coś, co może zadziałać, ale nie mogę znaleźć żadnych prawdziwych informacji o tym, jak go użyć. Wszystko, co widziałem, to ludzie tworzą dla niej statyczną instancję, ale w jaki sposób odzyskujesz i uzyskujesz dostęp do informacji w innej procedurze? Zakładając, że to właściwa metoda.

Moje pytanie brzmi: w jaki sposób przekazujesz informacje pomiędzy modułami obsługi w tym samym potoku. W powyższym przykładzie w jaki sposób przekazać dane logowania od AuthenticationServerHandler do BusinessLogicServerHandler?

Answer 1

ChannelLocal to sposób na bankomaty. Po prostu stwórz gdzieś instancję statyczną, a następnie uzyskaj dostęp do niej za pomocą programów obsługi, przekazując kanał do metody set/get. W ten sposób możesz udostępniać treści między kanałami.

Answer 2

nie byłem fanem ChannelLocal realizacji z brakiem wewnętrznej mapie statycznej, więc co skończyło się robi było umieszczenie mojego obiektu na zajęcia kanału dla teraz:

ctx.getChannel().setAttachment(myobj); 

Potem robię "myobj" w zasadzie POJO kontekstu, który zawiera wszystkie informacje zebrane na temat żądania do tej pory.

public class RequestContext { 
    private String foo = ""; 

    public String getFoo(){ 
     return foo; 
    } 
    public void setFoo(String foo){ 
     this.foo = foo; 
    } 

} 

RequestContext reqCtx = new RequestContext(); 
reqCtx.setFoo("Bar"); 

ctx.getChannel().setAttachment(reqCtx); 
reqCtx = (RequestContext)ctx.getChannel().getAttachment(); 

To nie jest eleganckie, ale działa ...

Answer 3

przekazać informację od jednego przewodnika do następnych nich za pomocą dedykowanych wystąpień komponować gazociągu dla każdego kanału, a poprzez odniesienie do każdej procedury obsługi inne w każdym rurociągu.

Przekazywanie informacji odbywa się starą drogą, bardzo prosto, bez żadnego problemu.