239.7. usage Samples

RouteBuilder builder = new RouteBuilder() {
  public void configure() {
    from("netty:udp://0.0.0.0:5155?sync=true")
      .process(new Processor() {
         public void process(Exchange exchange) throws Exception {
           Poetry poetry = (Poetry) exchange.getIn().getBody();
           poetry.setPoet("Dr. Sarojini Naidu");
           exchange.getOut().setBody(poetry);
         }
       }
    }
};

RouteBuilder builder = new RouteBuilder() {
  public void configure() {
       from("netty:tcp://0.0.0.0:5150")
           .to("mock:result");
  }
};

JSSE 설정 사용

Camel 2.9부터 Netty 구성 요소는 Camel JSSE ConfigurationECDHE를 통해 SSL/TLS 구성을 지원합니다.  이 유틸리티는 작성해야 하는 구성 요소 특정 코드의 양을 크게 줄이고 끝점 및 구성 요소 수준에서 구성할 수 있습니다.  다음 예제에서는 Netty 구성 요소에서 유틸리티를 사용하는 방법을 보여줍니다.

구성 요소의 프로그래밍 방식 구성

KeyStoreParameters ksp = new KeyStoreParameters();
ksp.setResource("/users/home/server/keystore.jks");
ksp.setPassword("keystorePassword");

KeyManagersParameters kmp = new KeyManagersParameters();
kmp.setKeyStore(ksp);
kmp.setKeyPassword("keyPassword");

SSLContextParameters scp = new SSLContextParameters();
scp.setKeyManagers(kmp);

NettyComponent nettyComponent = getContext().getComponent("netty", NettyComponent.class);
nettyComponent.setSslContextParameters(scp);

Spring DSL 기반 엔드 포인트 구성

...
  <camel:sslContextParameters
      id="sslContextParameters">
    <camel:keyManagers
        keyPassword="keyPassword">
      <camel:keyStore
          resource="/users/home/server/keystore.jks"
          password="keystorePassword"/>
    </camel:keyManagers>
  </camel:sslContextParameters>...
...
  <to uri="netty:tcp://0.0.0.0:5150?sync=true&ssl=true&sslContextParameters=#sslContextParameters"/>
...

ECDHEty Component에서 기본 SSL/TLS 구성 사용

JndiRegistry registry = new JndiRegistry(createJndiContext());
registry.bind("password", "changeit");
registry.bind("ksf", new File("src/test/resources/keystore.jks"));
registry.bind("tsf", new File("src/test/resources/keystore.jks"));

context.createRegistry(registry);
context.addRoutes(new RouteBuilder() {
  public void configure() {
      String netty_ssl_endpoint =
         "netty:tcp://0.0.0.0:5150?sync=true&ssl=true&passphrase=#password"
         + "&keyStoreFile=#ksf&trustStoreFile=#tsf";
      String return_string =
         "When You Go Home, Tell Them Of Us And Say,"
         + "For Your Tomorrow, We Gave Our Today.";

      from(netty_ssl_endpoint)
       .process(new Processor() {
          public void process(Exchange exchange) throws Exception {
            exchange.getOut().setBody(return_string);
          }
       }
  }
});

SSLSession 및 클라이언트 인증서에 액세스

Camel 2.12에서 사용 가능

클라이언트 인증서에 대한 세부 정보를 가져와야 하는 경우 javax.net.ssl.SSLSession 에 액세스할 수 있습니다. ssl=true 인 경우 Netty 구성 요소는 다음과 같이 Camel Message의 헤더로 SSLSession 을 저장합니다.

SSLSession session = exchange.getIn().getHeader(NettyConstants.NETTY_SSL_SESSION, SSLSession.class);
// get the first certificate which is client certificate
javax.security.cert.X509Certificate cert = session.getPeerCertificateChain()[0];
Principal principal = cert.getSubjectDN();

클라이언트를 인증하기 위해 needClientAuth=true 를 설정해야 합니다. 그렇지 않으면 SSLSession 에서 클라이언트 인증서에 대한 정보에 액세스할 수 없으며 예외 javax.net.ssl.SSLPeerUnverifiedException: peer not authenticated. 클라이언트 인증서가 만료되었거나 유효하지 않은 경우에도 이 예외가 발생할 수 있습니다.

특정 경우에는 netty 파이프라인에 인코더 및 디코더 체인을 추가해야 할 수 있습니다. camel netty 엔드포인트에 여러 개의 codecs를 추가하려면 'encoders' 및 'decoders' uri 매개 변수를 사용해야 합니다. 파이프라인에 추가해야 하는 'encoder' 및 'decoder' 매개변수와 마찬가지로 참조( ChannelUpstreamHandler 및 ChannelDownstreamHandlers 목록)를 제공하는 데 사용됩니다. 인코더가 지정되면 인코더 매개변수가 무시되며 디코더 및 디코더 매개 변수가 무시됩니다.

엔드포인트를 생성할 때 이를 해결할 수 있도록 Camel의 레지스트리에 codecs 목록을 추가해야 합니다.

Spring의 네이티브 컬렉션 지원을 사용하여 애플리케이션 컨텍스트에서 codec 목록을 지정할 수 있습니다.

그런 다음 빈 이름을 쉼표로 구분된 목록으로 사용하거나 목록에 포함된 netty 엔드포인트 정의에서 사용할 수 있습니다. 예를 들면 다음과 같습니다.

또는 봄을 통해.