javax.net.ssl.SSLEngine.getUseClientMode()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(7.5k)|赞(0)|评价(0)|浏览(140)

本文整理了Java中javax.net.ssl.SSLEngine.getUseClientMode()方法的一些代码示例，展示了SSLEngine.getUseClientMode()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。SSLEngine.getUseClientMode()方法的具体详情如下：
包路径：javax.net.ssl.SSLEngine
类名称：SSLEngine
方法名：getUseClientMode

SSLEngine.getUseClientMode介绍

[英]Returns whether this engine is set to act in client mode when handshaking.
[中]返回握手时此引擎是否设置为在客户端模式下运行。

代码示例

代码示例来源：origin: redisson/redisson

  1. @Override
  2. public boolean getUseClientMode() {
  3.   return engine.getUseClientMode();
  4. }

代码示例来源：origin: wildfly/wildfly

  1. @Override
  2. public boolean getUseClientMode() {
  3.   return engine.getUseClientMode();
  4. }

代码示例来源：origin: wildfly/wildfly

  1. @Override
  2. public boolean getUseClientMode() {
  3.   return delegate.getUseClientMode();
  4. }

代码示例来源：origin: wildfly/wildfly

  1. @Override
  2. public boolean getUseClientMode() {
  3.   return delegate.getUseClientMode();
  4. }

代码示例来源：origin: wildfly/wildfly

  1. public boolean isClientMode() {
  2.     return engine.getUseClientMode();
  3.   }
  4. };

代码示例来源：origin: wildfly/wildfly

  1. public boolean getUseClientMode() {
  2.   return delegate.getUseClientMode();
  3. }

代码示例来源：origin: io.netty/netty

  1. @Override
  2. public boolean getUseClientMode() {
  3.   return engine.getUseClientMode();
  4. }

代码示例来源：origin: wildfly/wildfly

  1. public boolean getUseClientMode() {
  2.   return currentRef.get().getUseClientMode();
  3. }

代码示例来源：origin: wildfly/wildfly

  1. public boolean getUseClientMode() {
  2.   return currentRef.get().getUseClientMode();
  3. }

代码示例来源：origin: wildfly/wildfly

  1. public boolean getUseClientMode() {
  2.   return currentRef.get().getUseClientMode();
  3. }

代码示例来源：origin: redisson/redisson

  1. private void startHandshakeProcessing() {
  2.   if (!handshakeStarted) {
  3.     handshakeStarted = true;
  4.     if (engine.getUseClientMode()) {
  5.       // Begin the initial handshake.
  6.       // channelActive() event has been fired already, which means this.channelActive() will
  7.       // not be invoked. We have to initialize here instead.
  8.       handshake();
  9.     }
  10.     applyHandshakeTimeout();
  11.   }
  12. }

代码示例来源：origin: wildfly/wildfly

  1. private void startHandshakeProcessing() {
  2.   handshakeStarted = true;
  3.   if (engine.getUseClientMode()) {
  4.     // Begin the initial handshake.
  5.     // channelActive() event has been fired already, which means this.channelActive() will
  6.     // not be invoked. We have to initialize here instead.
  7.     handshake(null);
  8.   } else {
  9.     applyHandshakeTimeout(null);
  10.   }
  11. }

代码示例来源：origin: JZ-Darkal/AndroidHttpCapture

  1. private void filterWeakCipherSuites(SSLEngine sslEngine) {
  2.   List<String> ciphers = new LinkedList<String>();
  3.   for (String each : sslEngine.getEnabledCipherSuites()) {
  4.     if (each.equals("TLS_DHE_RSA_WITH_AES_128_CBC_SHA") || each.equals("TLS_DHE_RSA_WITH_AES_256_CBC_SHA")) {
  5.       LOG.debug("Removed cipher {}", each);
  6.     } else {
  7.       ciphers.add(each);
  8.     }
  9.   }
  10.   sslEngine.setEnabledCipherSuites(ciphers.toArray(new String[ciphers.size()]));
  11.   if (LOG.isDebugEnabled()) {
  12.     if (sslEngine.getUseClientMode()) {
  13.       LOG.debug("Enabled server cipher suites:");
  14.     } else {
  15.       String host = sslEngine.getPeerHost();
  16.       int port = sslEngine.getPeerPort();
  17.       LOG.debug("Enabled client {}:{} cipher suites:", host, port);
  18.     }
  19.     for (String each : ciphers) {
  20.       LOG.debug(each);
  21.     }
  22.   }
  23. }

代码示例来源：origin: org.mongodb/mongo-java-driver

  1. private ClientTlsChannel(
  2.     final ByteChannel underlying,
  3.     final SSLEngine engine,
  4.     final Consumer<SSLSession> sessionInitCallback,
  5.     final boolean runTasks,
  6.     final BufferAllocator plainBufAllocator,
  7.     final BufferAllocator encryptedBufAllocator,
  8.     final boolean releaseBuffers,
  9.     final boolean waitForCloseNotifyOnClose) {
  10.   if (!engine.getUseClientMode()) {
  11.     throw new IllegalArgumentException("SSLEngine must be in client mode");
  12.   }
  13.   this.underlying = underlying;
  14.   TrackingAllocator trackingPlainBufAllocator = new TrackingAllocator(plainBufAllocator);
  15.   TrackingAllocator trackingEncryptedAllocator = new TrackingAllocator(encryptedBufAllocator);
  16.   impl = new TlsChannelImpl(underlying, underlying, engine, Optional.<BufferHolder>empty(), sessionInitCallback, runTasks,
  17.       trackingPlainBufAllocator, trackingEncryptedAllocator, releaseBuffers, waitForCloseNotifyOnClose);
  18. }

代码示例来源：origin: wildfly/wildfly

  1. static SSLEngine setProtocols(final SSLEngine engine, final String[] protocols) {
  2.     if (engine.getUseClientMode()) {
  3.       ALPN.put(engine, new ALPNClientSelectionProvider(Arrays.asList(protocols), engine));
  4.     } else {
  5.       ALPN.put(engine, new ALPN.ServerProvider() {
  6.         @Override
  7.         public void unsupported() {
  8.           ALPN.remove(engine);
  9.         }
  10.         @Override
  11.         public String select(List<String> strings) {
  12.           ALPN.remove(engine);
  13.           for (String p : protocols) {
  14.             if (strings.contains(p)) {
  15.               engine.getHandshakeSession().putValue(PROTOCOL_KEY, p);
  16.               return p;
  17.             }
  18.           }
  19.           return null;
  20.         }
  21.       });
  22.     }
  23.     return engine;
  24.   }
  25. }

代码示例来源：origin: apache/kafka

  1. @Test
  2. public void testClientMode() throws Exception {
  3.   File trustStoreFile = File.createTempFile("truststore", ".jks");
  4.   Map<String, Object> clientSslConfig = TestSslUtils.createSslConfig(false, true, Mode.CLIENT, trustStoreFile, "client");
  5.   SslFactory sslFactory = new SslFactory(Mode.CLIENT);
  6.   sslFactory.configure(clientSslConfig);
  7.   //host and port are hints
  8.   SSLEngine engine = sslFactory.createSslEngine("localhost", 0);
  9.   assertTrue(engine.getUseClientMode());
  10. }

代码示例来源：origin: apache/kafka

  1. @Test
  2. public void testSslFactoryConfiguration() throws Exception {
  3.   File trustStoreFile = File.createTempFile("truststore", ".jks");
  4.   Map<String, Object> serverSslConfig = TestSslUtils.createSslConfig(false, true, Mode.SERVER, trustStoreFile, "server");
  5.   SslFactory sslFactory = new SslFactory(Mode.SERVER);
  6.   sslFactory.configure(serverSslConfig);
  7.   //host and port are hints
  8.   SSLEngine engine = sslFactory.createSslEngine("localhost", 0);
  9.   assertNotNull(engine);
  10.   String[] expectedProtocols = {"TLSv1.2"};
  11.   assertArrayEquals(expectedProtocols, engine.getEnabledProtocols());
  12.   assertEquals(false, engine.getUseClientMode());
  13. }

代码示例来源：origin: apache/kafka

  1. assertNotNull("SSL context not created", sslContext);
  2. assertSame("SSL context recreated unnecessarily", sslContext, sslFactory.sslContext());
  3. assertFalse(sslFactory.createSslEngine("localhost", 0).getUseClientMode());

代码示例来源：origin: wildfly/wildfly

  1. SslConduit(UndertowSslConnection connection, StreamConnection delegate, SSLEngine engine, ByteBufferPool bufferPool, Runnable handshakeCallback) {
  2.   this.connection = connection;
  3.   this.delegate = delegate;
  4.   this.handshakeCallback = handshakeCallback;
  5.   this.sink = delegate.getSinkChannel().getConduit();
  6.   this.source = delegate.getSourceChannel().getConduit();
  7.   this.engine = engine;
  8.   this.bufferPool = bufferPool;
  9.   delegate.getSourceChannel().getConduit().setReadReadyHandler(readReadyHandler = new SslReadReadyHandler(null));
  10.   delegate.getSinkChannel().getConduit().setWriteReadyHandler(writeReadyHandler = new SslWriteReadyHandler(null));
  11.   if(engine.getUseClientMode()) {
  12.     state = FLAG_IN_HANDSHAKE | FLAG_READ_REQUIRES_WRITE;
  13.   } else {
  14.     state = FLAG_IN_HANDSHAKE | FLAG_WRITE_REQUIRES_READ;
  15.   }
  16. }

代码示例来源：origin: igniterealtime/Openfire

  1. /**
  2.  * A utility method that implements the shared functionality of getServerModeSslFilter and getClientModeSslFilter.
  3.  *
  4.  * This method is used to initialize and configure an instance of SslFilter for a particular pre-configured
  5.  * SSLContext and SSLEngine. In most cases, developers will want to use getServerModeSslFilter or
  6.  * getClientModeSslFilter instead of this method.
  7.  *
  8.  * @param sslContext a pre-configured SSL Context instance (cannot be null).
  9.  * @param sslEngine a pre-configured SSL Engine instance (cannot be null).
  10.  * @return A SslFilter instance (never null).
  11.  */
  12. private static SslFilter createSslFilter( SSLContext sslContext, SSLEngine sslEngine ) {
  13.   final SslFilter filter = new SslFilter( sslContext );
  14.   // Copy configuration from the SSL Engine into the filter.
  15.   filter.setUseClientMode( sslEngine.getUseClientMode() );
  16.   filter.setEnabledProtocols( sslEngine.getEnabledProtocols() );
  17.   filter.setEnabledCipherSuites( sslEngine.getEnabledCipherSuites() );
  18.   // Note that the setters for 'need' and 'want' influence each-other. Invoke only one of them!
  19.   if ( sslEngine.getNeedClientAuth() )
  20.   {
  21.     filter.setNeedClientAuth( true );
  22.   }
  23.   else if ( sslEngine.getWantClientAuth() )
  24.   {
  25.     filter.setWantClientAuth( true );
  26.   }
  27.   return filter;
  28. }

内容来源于网络，如有侵权，请联系作者删除！

sslengine

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    SSLEngine类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com