Java SSLFilter类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.apache.mina.filter.SSLFilter类的典型用法代码示例。如果您正苦于以下问题：Java SSLFilter类的具体用法？Java SSLFilter怎么用？Java SSLFilter使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

SSLFilter类属于org.apache.mina.filter包，在下文中一共展示了SSLFilter类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: write

import org.apache.mina.filter.SSLFilter; //导入依赖的package包/类
@Override
public WriteFuture write(Object message) {
    DefaultWriteFuture ret = new DefaultWriteFuture(this);
    try {
        otherEnd.messageReceived(nextFilter, otherSession, message);
        ret.setWritten(true);
    }
    catch (Exception e) {
        e.printStackTrace();
        ret.setWritten(false);
    }
    // behave like the real thing..
    if (attributes.get(SSLFilter.DISABLE_ENCRYPTION_ONCE) != null) {
        attributes.remove(SSLFilter.DISABLE_ENCRYPTION_ONCE);
    }
    return ret;
}

开发者ID:betfair，项目名称:cougar，代码行数:18，代码来源:CougarProtocolTest.java

示例2: getLocalCertificates

import org.apache.mina.filter.SSLFilter; //导入依赖的package包/类
public Certificate[] getLocalCertificates() {
    SSLSession sslSession = (SSLSession) ioSession.getAttribute(SSLFilter.SSL_SESSION);
    if (sslSession != null) {
        return sslSession.getLocalCertificates();
    }
    return new Certificate[0];
}

开发者ID:coodeer，项目名称:g3server，代码行数:8，代码来源:NIOConnection.java

示例3: getPeerCertificates

import org.apache.mina.filter.SSLFilter; //导入依赖的package包/类
public Certificate[] getPeerCertificates() {
    try {
        SSLSession sslSession = (SSLSession) ioSession.getAttribute(SSLFilter.SSL_SESSION);
        if (sslSession != null) {
            return sslSession.getPeerCertificates();
        }
    } catch (SSLPeerUnverifiedException e) {
        Log.warn("Error retrieving client certificates of: " + session, e);
    }
    return new Certificate[0];
}

开发者ID:coodeer，项目名称:g3server，代码行数:12，代码来源:NIOConnection.java

示例4: sessionCreated

import org.apache.mina.filter.SSLFilter; //导入依赖的package包/类
public void sessionCreated(IoSession ioSession) throws Exception
{
    if(log.isDebugEnabled())
    {
        log.debug("Created session: " + ioSession.getRemoteAddress());
    }

    SessionUtil.initialize(ioSession);
    IoFilterChain chain = ioSession.getFilterChain();

  if (_sslFactory != null)
    {
        // at the time of initializing sslfactory no 'protocolFilter' is created. Hence we need to add 'sslFilter' as first in filter chain.
        chain.addFirst("sslFilter", new SSLFilter(_sslFactory.buildServerContext()));

    }

    if (_factory != null)
    {
       NetworkConnection netConn = new MinaNetworkConnection(ioSession);

       ProtocolEngine engine = _factory.newProtocolEngine(netConn);
       ioSession.setAttachment(engine);
    }

    // We limit the size of receiving buffer to 1 MB
    ReadThrottleFilterBuilder readFilter = new ReadThrottleFilterBuilder();
    readFilter.setMaximumConnectionBufferSize(1024*1024);
    readFilter.attach(chain);
}

开发者ID:wso2，项目名称:andes，代码行数:31，代码来源:MinaNetworkHandler.java

示例5: CougarProtocol

import org.apache.mina.filter.SSLFilter; //导入依赖的package包/类
protected CougarProtocol(boolean server, NioLogger nioLogger, int keepAliveInterval, int keepAliveTimeout, SSLFilter sslFilter, boolean supportsTls, boolean requiresTls, long rpcTimeoutMillis) {
    this.isServer = server;
    this.nioLogger = nioLogger;
    this.interval = keepAliveInterval;
    this.timeout = keepAliveTimeout;
    this.sslFilter = sslFilter;
    this.supportsTls = supportsTls;
    this.requiresTls = requiresTls;
    this.rpcTimeoutMillis = rpcTimeoutMillis;
    export(nioLogger.getJmxControl());
}

开发者ID:betfair，项目名称:cougar，代码行数:12，代码来源:CougarProtocol.java

示例6: CougarProtocol4

import org.apache.mina.filter.SSLFilter; //导入依赖的package包/类
protected CougarProtocol4(boolean server, NioLogger nioLogger, int keepAliveInterval, int keepAliveTimeout, SSLFilter sslFilter, boolean supportsTls, boolean requiresTls, long rpcTimeoutMillis) {
    super(server, nioLogger, keepAliveInterval, keepAliveTimeout, sslFilter, supportsTls, requiresTls, rpcTimeoutMillis);
    this.isServer = server;
    this.nioLogger = nioLogger;
    this.interval = keepAliveInterval;
    this.timeout = keepAliveTimeout;
    this.sslFilter = sslFilter;
    this.supportsTls = supportsTls;
    this.requiresTls = requiresTls;
    this.rpcTimeoutMillis = rpcTimeoutMillis;
    export(nioLogger.getJmxControl());
}

开发者ID:betfair，项目名称:cougar，代码行数:13，代码来源:CougarProtocol4.java

示例7: CougarProtocol3

import org.apache.mina.filter.SSLFilter; //导入依赖的package包/类
protected CougarProtocol3(boolean server, NioLogger nioLogger, int keepAliveInterval, int keepAliveTimeout, SSLFilter sslFilter, boolean supportsTls, boolean requiresTls, long rpcTimeoutMillis) {
    this.isServer = server;
    this.nioLogger = nioLogger;
    this.interval = keepAliveInterval;
    this.timeout = keepAliveTimeout;
    this.sslFilter = sslFilter;
    this.supportsTls = supportsTls;
    this.requiresTls = requiresTls;
    this.rpcTimeoutMillis = rpcTimeoutMillis;
    export(nioLogger.getJmxControl());
}

开发者ID:betfair，项目名称:cougar，代码行数:12，代码来源:CougarProtocol3.java

示例8: secureClientSupportsTlsNoClientAuthTruststoreProvided

import org.apache.mina.filter.SSLFilter; //导入依赖的package包/类
@Test
public void secureClientSupportsTlsNoClientAuthTruststoreProvided() throws IOException {
    TlsNioConfig config = new TlsNioConfig();
    config.setNioLogger(logger);
    config.setMbeanServer(mbeanServer);
    config.setTruststore(new FileSystemResource(getClientTruststorePath()));
    config.setTruststorePassword("password");
    config.setTruststoreType("JKS");
    config.setWantClientAuth(false);
    config.setNeedClientAuth(false);
    config.setRequiresTls(false);
    config.setSupportsTls(true);
    config.configureProtocol(minaConfig, false);

    List<Tuple<String, IoFilter>> addedFilters = getAddedFilters();
    assertEquals("slowHandling", addedFilters.get(0).getFirst());
    assertInstanceOf(SessionWriteQueueMonitoring.class, addedFilters.get(0).getSecond());
    assertEquals("codec", addedFilters.get(1).getFirst());
    assertInstanceOf(ProtocolCodecFilter.class, addedFilters.get(1).getSecond());
    assertEquals("protocol", addedFilters.get(2).getFirst());
    assertInstanceOf(CougarProtocol.class, addedFilters.get(2).getSecond());

    CougarProtocol cp = (CougarProtocol) addedFilters.get(2).getSecond();
    assertFalse(cp.isRequiresTls());
    assertTrue(cp.isSupportsTls());
    assertNotNull(cp.getSslFilter());
    SSLFilter sslFilter = cp.getSslFilter();
    assertFalse(sslFilter.isNeedClientAuth());
    assertFalse(sslFilter.isWantClientAuth());
    assertTrue(sslFilter.isUseClientMode());
    assertNull(sslFilter.getEnabledCipherSuites());
}

开发者ID:betfair，项目名称:cougar，代码行数:33，代码来源:TlsNioConfigTest.java

示例9: secureClientSupportsTlsNoClientAuthTruststoreProvidedSpecifiedCiphers

import org.apache.mina.filter.SSLFilter; //导入依赖的package包/类
@Test
public void secureClientSupportsTlsNoClientAuthTruststoreProvidedSpecifiedCiphers() throws IOException {
    TlsNioConfig config = new TlsNioConfig();
    config.setNioLogger(logger);
    config.setMbeanServer(mbeanServer);
    config.setTruststore(new FileSystemResource(getClientTruststorePath()));
    config.setTruststorePassword("password");
    config.setTruststoreType("JKS");
    config.setWantClientAuth(false);
    config.setNeedClientAuth(false);
    config.setRequiresTls(false);
    config.setSupportsTls(true);
    config.setAllowedCipherSuites("DES,AES");
    config.configureProtocol(minaConfig, false);

    List<Tuple<String, IoFilter>> addedFilters = getAddedFilters();
    assertEquals("slowHandling", addedFilters.get(0).getFirst());
    assertInstanceOf(SessionWriteQueueMonitoring.class, addedFilters.get(0).getSecond());
    assertEquals("codec", addedFilters.get(1).getFirst());
    assertInstanceOf(ProtocolCodecFilter.class, addedFilters.get(1).getSecond());
    assertEquals("protocol", addedFilters.get(2).getFirst());
    assertInstanceOf(CougarProtocol.class, addedFilters.get(2).getSecond());

    CougarProtocol cp = (CougarProtocol) addedFilters.get(2).getSecond();
    assertFalse(cp.isRequiresTls());
    assertTrue(cp.isSupportsTls());
    assertNotNull(cp.getSslFilter());
    SSLFilter sslFilter = cp.getSslFilter();
    assertFalse(sslFilter.isNeedClientAuth());
    assertFalse(sslFilter.isWantClientAuth());
    assertTrue(sslFilter.isUseClientMode());
    assertNotNull(sslFilter.getEnabledCipherSuites());
    assertEquals(2, sslFilter.getEnabledCipherSuites().length);
}

开发者ID:betfair，项目名称:cougar，代码行数:35，代码来源:TlsNioConfigTest.java

示例10: secureClientSupportsTlsWantsClientAuthTruststoreProvidedKeystoreProvided

import org.apache.mina.filter.SSLFilter; //导入依赖的package包/类
@Test
public void secureClientSupportsTlsWantsClientAuthTruststoreProvidedKeystoreProvided() throws IOException {
    TlsNioConfig config = new TlsNioConfig();
    config.setNioLogger(logger);
    config.setMbeanServer(mbeanServer);
    config.setTruststore(new FileSystemResource(getClientTruststorePath()));
    config.setTruststorePassword("password");
    config.setTruststoreType("JKS");
    config.setKeystore(new FileSystemResource(getClientKeystorePath()));
    config.setKeystorePassword("password");
    config.setKeystoreType("JKS");
    config.setWantClientAuth(true);
    config.setNeedClientAuth(false);
    config.setRequiresTls(false);
    config.setSupportsTls(true);
    config.configureProtocol(minaConfig, false);

    List<Tuple<String, IoFilter>> addedFilters = getAddedFilters();
    assertEquals("slowHandling", addedFilters.get(0).getFirst());
    assertInstanceOf(SessionWriteQueueMonitoring.class, addedFilters.get(0).getSecond());
    assertEquals("codec", addedFilters.get(1).getFirst());
    assertInstanceOf(ProtocolCodecFilter.class, addedFilters.get(1).getSecond());
    assertEquals("protocol", addedFilters.get(2).getFirst());
    assertInstanceOf(CougarProtocol.class, addedFilters.get(2).getSecond());

    CougarProtocol cp = (CougarProtocol) addedFilters.get(2).getSecond();
    assertFalse(cp.isRequiresTls());
    assertTrue(cp.isSupportsTls());
    assertNotNull(cp.getSslFilter());
    SSLFilter sslFilter = cp.getSslFilter();
    assertFalse(sslFilter.isNeedClientAuth());
    assertTrue(sslFilter.isWantClientAuth());
    assertTrue(sslFilter.isUseClientMode());
    assertNull(sslFilter.getEnabledCipherSuites());
}

开发者ID:betfair，项目名称:cougar，代码行数:36，代码来源:TlsNioConfigTest.java

示例11: secureClientSupportsTlsNeedsClientAuthTruststoreProvidedKeystoreProvided

import org.apache.mina.filter.SSLFilter; //导入依赖的package包/类
@Test
public void secureClientSupportsTlsNeedsClientAuthTruststoreProvidedKeystoreProvided() throws IOException {
    TlsNioConfig config = new TlsNioConfig();
    config.setNioLogger(logger);
    config.setMbeanServer(mbeanServer);
    config.setTruststore(new FileSystemResource(getClientTruststorePath()));
    config.setTruststorePassword("password");
    config.setTruststoreType("JKS");
    config.setKeystore(new FileSystemResource(getClientKeystorePath()));
    config.setKeystorePassword("password");
    config.setKeystoreType("JKS");
    config.setWantClientAuth(true);
    config.setNeedClientAuth(false);
    config.setRequiresTls(false);
    config.setSupportsTls(true);
    config.configureProtocol(minaConfig, false);

    List<Tuple<String, IoFilter>> addedFilters = getAddedFilters();
    assertEquals("slowHandling", addedFilters.get(0).getFirst());
    assertInstanceOf(SessionWriteQueueMonitoring.class, addedFilters.get(0).getSecond());
    assertEquals("codec", addedFilters.get(1).getFirst());
    assertInstanceOf(ProtocolCodecFilter.class, addedFilters.get(1).getSecond());
    assertEquals("protocol", addedFilters.get(2).getFirst());
    assertInstanceOf(CougarProtocol.class, addedFilters.get(2).getSecond());

    CougarProtocol cp = (CougarProtocol) addedFilters.get(2).getSecond();
    assertFalse(cp.isRequiresTls());
    assertTrue(cp.isSupportsTls());
    assertNotNull(cp.getSslFilter());
    SSLFilter sslFilter = cp.getSslFilter();
    assertFalse(sslFilter.isNeedClientAuth());
    assertTrue(sslFilter.isWantClientAuth());
    assertTrue(sslFilter.isUseClientMode());
    assertNull(sslFilter.getEnabledCipherSuites());
}

开发者ID:betfair，项目名称:cougar，代码行数:36，代码来源:TlsNioConfigTest.java

示例12: secureClientRequiresTlsNoClientAuthTruststoreProvided

import org.apache.mina.filter.SSLFilter; //导入依赖的package包/类
@Test
public void secureClientRequiresTlsNoClientAuthTruststoreProvided() throws IOException {
    TlsNioConfig config = new TlsNioConfig();
    config.setNioLogger(logger);
    config.setMbeanServer(mbeanServer);
    config.setTruststore(new FileSystemResource(getClientTruststorePath()));
    config.setTruststorePassword("password");
    config.setTruststoreType("JKS");
    config.setWantClientAuth(false);
    config.setNeedClientAuth(false);
    config.setRequiresTls(true);
    config.setSupportsTls(true);
    config.configureProtocol(minaConfig, false);

    List<Tuple<String, IoFilter>> addedFilters = getAddedFilters();
    assertEquals("slowHandling", addedFilters.get(0).getFirst());
    assertInstanceOf(SessionWriteQueueMonitoring.class, addedFilters.get(0).getSecond());
    assertEquals("codec", addedFilters.get(1).getFirst());
    assertInstanceOf(ProtocolCodecFilter.class, addedFilters.get(1).getSecond());
    assertEquals("protocol", addedFilters.get(2).getFirst());
    assertInstanceOf(CougarProtocol.class, addedFilters.get(2).getSecond());

    CougarProtocol cp = (CougarProtocol) addedFilters.get(2).getSecond();
    assertTrue(cp.isRequiresTls());
    assertTrue(cp.isSupportsTls());
    assertNotNull(cp.getSslFilter());
    SSLFilter sslFilter = cp.getSslFilter();
    assertFalse(sslFilter.isNeedClientAuth());
    assertFalse(sslFilter.isWantClientAuth());
    assertTrue(sslFilter.isUseClientMode());
    assertNull(sslFilter.getEnabledCipherSuites());
}

开发者ID:betfair，项目名称:cougar，代码行数:33，代码来源:TlsNioConfigTest.java

示例13: secureServerSupportsTlsNoClientAuthKeystoreProvided

import org.apache.mina.filter.SSLFilter; //导入依赖的package包/类
@Test
public void secureServerSupportsTlsNoClientAuthKeystoreProvided() throws IOException {
    TlsNioConfig config = new TlsNioConfig();
    config.setNioLogger(logger);
    config.setMbeanServer(mbeanServer);
    config.setKeystore(new FileSystemResource(getServerKeystorePath()));
    config.setKeystorePassword("password");
    config.setKeystoreType("JKS");
    config.setWantClientAuth(false);
    config.setNeedClientAuth(false);
    config.setRequiresTls(false);
    config.setSupportsTls(true);
    config.configureProtocol(minaConfig, true);

    List<Tuple<String, IoFilter>> addedFilters = getAddedFilters();
    assertEquals("slowHandling", addedFilters.get(0).getFirst());
    assertInstanceOf(SessionWriteQueueMonitoring.class, addedFilters.get(0).getSecond());
    assertEquals("codec", addedFilters.get(1).getFirst());
    assertInstanceOf(ProtocolCodecFilter.class, addedFilters.get(1).getSecond());
    assertEquals("protocol", addedFilters.get(2).getFirst());
    assertInstanceOf(CougarProtocol.class, addedFilters.get(2).getSecond());

    CougarProtocol cp = (CougarProtocol) addedFilters.get(2).getSecond();
    assertFalse(cp.isRequiresTls());
    assertTrue(cp.isSupportsTls());
    assertNotNull(cp.getSslFilter());
    SSLFilter sslFilter = cp.getSslFilter();
    assertFalse(sslFilter.isNeedClientAuth());
    assertFalse(sslFilter.isWantClientAuth());
    assertFalse(sslFilter.isUseClientMode());
    assertNull(sslFilter.getEnabledCipherSuites());
}

开发者ID:betfair，项目名称:cougar，代码行数:33，代码来源:TlsNioConfigTest.java

示例14: secureServerSupportsTlsNoClientAuthKeystoreProvidedSpecifiedCiphers

import org.apache.mina.filter.SSLFilter; //导入依赖的package包/类
@Test
public void secureServerSupportsTlsNoClientAuthKeystoreProvidedSpecifiedCiphers() throws IOException {
    TlsNioConfig config = new TlsNioConfig();
    config.setNioLogger(logger);
    config.setMbeanServer(mbeanServer);
    config.setKeystore(new FileSystemResource(getServerKeystorePath()));
    config.setKeystorePassword("password");
    config.setKeystoreType("JKS");
    config.setWantClientAuth(false);
    config.setNeedClientAuth(false);
    config.setRequiresTls(false);
    config.setSupportsTls(true);
    config.setAllowedCipherSuites("DES,AES");
    config.configureProtocol(minaConfig, true);

    List<Tuple<String, IoFilter>> addedFilters = getAddedFilters();
    assertEquals("slowHandling", addedFilters.get(0).getFirst());
    assertInstanceOf(SessionWriteQueueMonitoring.class, addedFilters.get(0).getSecond());
    assertEquals("codec", addedFilters.get(1).getFirst());
    assertInstanceOf(ProtocolCodecFilter.class, addedFilters.get(1).getSecond());
    assertEquals("protocol", addedFilters.get(2).getFirst());
    assertInstanceOf(CougarProtocol.class, addedFilters.get(2).getSecond());

    CougarProtocol cp = (CougarProtocol) addedFilters.get(2).getSecond();
    assertFalse(cp.isRequiresTls());
    assertTrue(cp.isSupportsTls());
    assertNotNull(cp.getSslFilter());
    SSLFilter sslFilter = cp.getSslFilter();
    assertFalse(sslFilter.isNeedClientAuth());
    assertFalse(sslFilter.isWantClientAuth());
    assertFalse(sslFilter.isUseClientMode());
    assertNotNull(sslFilter.getEnabledCipherSuites());
    assertEquals(2, sslFilter.getEnabledCipherSuites().length);
}

开发者ID:betfair，项目名称:cougar，代码行数:35，代码来源:TlsNioConfigTest.java

示例15: secureServerSupportsTlsWantsClientAuthKeystoreProvidedTruststoreProvided

import org.apache.mina.filter.SSLFilter; //导入依赖的package包/类
@Test
public void secureServerSupportsTlsWantsClientAuthKeystoreProvidedTruststoreProvided() throws IOException {
    TlsNioConfig config = new TlsNioConfig();
    config.setNioLogger(logger);
    config.setMbeanServer(mbeanServer);
    config.setTruststore(new FileSystemResource(getServerTruststorePath()));
    config.setTruststorePassword("password");
    config.setTruststoreType("JKS");
    config.setKeystore(new FileSystemResource(getServerKeystorePath()));
    config.setKeystorePassword("password");
    config.setKeystoreType("JKS");
    config.setWantClientAuth(true);
    config.setNeedClientAuth(false);
    config.setRequiresTls(false);
    config.setSupportsTls(true);
    config.configureProtocol(minaConfig, true);

    List<Tuple<String, IoFilter>> addedFilters = getAddedFilters();
    assertEquals("slowHandling", addedFilters.get(0).getFirst());
    assertInstanceOf(SessionWriteQueueMonitoring.class, addedFilters.get(0).getSecond());
    assertEquals("codec", addedFilters.get(1).getFirst());
    assertInstanceOf(ProtocolCodecFilter.class, addedFilters.get(1).getSecond());
    assertEquals("protocol", addedFilters.get(2).getFirst());
    assertInstanceOf(CougarProtocol.class, addedFilters.get(2).getSecond());

    CougarProtocol cp = (CougarProtocol) addedFilters.get(2).getSecond();
    assertFalse(cp.isRequiresTls());
    assertTrue(cp.isSupportsTls());
    assertNotNull(cp.getSslFilter());
    SSLFilter sslFilter = cp.getSslFilter();
    assertFalse(sslFilter.isNeedClientAuth());
    assertTrue(sslFilter.isWantClientAuth());
    assertFalse(sslFilter.isUseClientMode());
    assertNull(sslFilter.getEnabledCipherSuites());
}

开发者ID:betfair，项目名称:cougar，代码行数:36，代码来源:TlsNioConfigTest.java

示例16: secureServerSupportsTlsNeedsClientAuthKeystoreProvidedTruststoreProvided

import org.apache.mina.filter.SSLFilter; //导入依赖的package包/类
@Test
public void secureServerSupportsTlsNeedsClientAuthKeystoreProvidedTruststoreProvided() throws IOException {
    TlsNioConfig config = new TlsNioConfig();
    config.setNioLogger(logger);
    config.setMbeanServer(mbeanServer);
    config.setTruststore(new FileSystemResource(getServerTruststorePath()));
    config.setTruststorePassword("password");
    config.setTruststoreType("JKS");
    config.setKeystore(new FileSystemResource(getServerKeystorePath()));
    config.setKeystorePassword("password");
    config.setKeystoreType("JKS");
    config.setWantClientAuth(true);
    config.setNeedClientAuth(false);
    config.setRequiresTls(false);
    config.setSupportsTls(true);
    config.configureProtocol(minaConfig, true);

    List<Tuple<String, IoFilter>> addedFilters = getAddedFilters();
    assertEquals("slowHandling", addedFilters.get(0).getFirst());
    assertInstanceOf(SessionWriteQueueMonitoring.class, addedFilters.get(0).getSecond());
    assertEquals("codec", addedFilters.get(1).getFirst());
    assertInstanceOf(ProtocolCodecFilter.class, addedFilters.get(1).getSecond());
    assertEquals("protocol", addedFilters.get(2).getFirst());
    assertInstanceOf(CougarProtocol.class, addedFilters.get(2).getSecond());

    CougarProtocol cp = (CougarProtocol) addedFilters.get(2).getSecond();
    assertFalse(cp.isRequiresTls());
    assertTrue(cp.isSupportsTls());
    assertNotNull(cp.getSslFilter());
    SSLFilter sslFilter = cp.getSslFilter();
    assertFalse(sslFilter.isNeedClientAuth());
    assertTrue(sslFilter.isWantClientAuth());
    assertFalse(sslFilter.isUseClientMode());
    assertNull(sslFilter.getEnabledCipherSuites());
}

开发者ID:betfair，项目名称:cougar，代码行数:36，代码来源:TlsNioConfigTest.java

示例17: secureServerRequiresTlsNoClientAuthKeystoreProvided

import org.apache.mina.filter.SSLFilter; //导入依赖的package包/类
@Test
public void secureServerRequiresTlsNoClientAuthKeystoreProvided() throws IOException {
    TlsNioConfig config = new TlsNioConfig();
    config.setNioLogger(logger);
    config.setMbeanServer(mbeanServer);
    config.setKeystore(new FileSystemResource(getServerKeystorePath()));
    config.setKeystorePassword("password");
    config.setKeystoreType("JKS");
    config.setWantClientAuth(false);
    config.setNeedClientAuth(false);
    config.setRequiresTls(true);
    config.setSupportsTls(true);
    config.configureProtocol(minaConfig, true);

    List<Tuple<String, IoFilter>> addedFilters = getAddedFilters();
    assertEquals("slowHandling", addedFilters.get(0).getFirst());
    assertInstanceOf(SessionWriteQueueMonitoring.class, addedFilters.get(0).getSecond());
    assertEquals("codec", addedFilters.get(1).getFirst());
    assertInstanceOf(ProtocolCodecFilter.class, addedFilters.get(1).getSecond());
    assertEquals("protocol", addedFilters.get(2).getFirst());
    assertInstanceOf(CougarProtocol.class, addedFilters.get(2).getSecond());

    CougarProtocol cp = (CougarProtocol) addedFilters.get(2).getSecond();
    assertTrue(cp.isRequiresTls());
    assertTrue(cp.isSupportsTls());
    assertNotNull(cp.getSslFilter());
    SSLFilter sslFilter = cp.getSslFilter();
    assertFalse(sslFilter.isNeedClientAuth());
    assertFalse(sslFilter.isWantClientAuth());
    assertFalse(sslFilter.isUseClientMode());
    assertNull(sslFilter.getEnabledCipherSuites());
}

开发者ID:betfair，项目名称:cougar，代码行数:33，代码来源:TlsNioConfigTest.java

示例18: connectFederationTLS

import org.apache.mina.filter.SSLFilter; //导入依赖的package包/类
/**
 * Create a connection to federation listener.
 */
private static IoSession connectFederationTLS (Router router,
                                               EwafURI uri,
                                               IoHandler listener)
  throws Exception
{
  SocketConnector connector = new SocketConnector (1, router.executor ());
  SocketConnectorConfig connectorConfig = new SocketConnectorConfig ();
  
  connector.setWorkerTimeout (0);
  
  connectorConfig.setThreadModel (ThreadModel.MANUAL);
  connectorConfig.setConnectTimeout (20);
  
  SSLFilter filter = new SSLFilter (defaultSSLContext ());
  
  filter.setUseClientMode (true);
  
  connectorConfig.getFilterChain ().addFirst ("ssl", filter);   
  
  connectorConfig.getFilterChain ().addLast   
    ("codec", FederationFrameCodec.FILTER);
  
  ConnectFuture future = 
    connector.connect (new InetSocketAddress (uri.host, uri.port),
                       listener, connectorConfig);
  
  future.join ();
  
  return future.getSession ();
}

开发者ID:luv，项目名称:avis_zmqprx，代码行数:34，代码来源:JUTestFederationTLS.java

示例19: createTLSConfig

import org.apache.mina.filter.SSLFilter; //导入依赖的package包/类
private static SocketConnectorConfig createTLSConfig () 
  throws Exception
{
  SocketConnectorConfig connectorConfig = createStandardConfig ();
  
  SSLContext sslContext = SSLContext.getInstance ("TLS");
  sslContext.init (null, new TrustManager [] {ACCEPT_ALL_MANAGER}, null);
  
  SSLFilter sslFilter = new SSLFilter (sslContext);
  sslFilter.setUseClientMode (true);
  
  connectorConfig.getFilterChain ().addFirst  ("ssl", sslFilter);
                              
  return connectorConfig;
}

开发者ID:luv，项目名称:avis_zmqprx，代码行数:16，代码来源:JUTestRouterTLS.java

示例20: createClientSSLListeners

import org.apache.mina.filter.SSLFilter; //导入依赖的package包/类
private void createClientSSLListeners() {
    // Start clients SSL unless it's been disabled.
    if (isClientSSLListenerEnabled()) {
        int port = getClientSSLListenerPort();
        String algorithm = JiveGlobals.getProperty("xmpp.socket.ssl.algorithm");
        if ("".equals(algorithm) || algorithm == null) {
            algorithm = "TLS";
        }
        try {
            // Create SocketAcceptor with correct number of processors
            sslSocketAcceptor = buildSocketAcceptor();
            // Customize Executor that will be used by processors to process incoming stanzas
            int eventThreads = JiveGlobals.getIntProperty("xmpp.client_ssl.processing.threads", 16);
            ExecutorFilter executorFilter = new ExecutorFilter();
            ThreadPoolExecutor eventExecutor = (ThreadPoolExecutor)executorFilter.getExecutor();
            final ThreadFactory originalThreadFactory = eventExecutor.getThreadFactory();
            ThreadFactory newThreadFactory = new ThreadFactory()
            {
                private final AtomicInteger threadId = new AtomicInteger( 0 );

                public Thread newThread( Runnable runnable )
                {
                    Thread t = originalThreadFactory.newThread( runnable );
                    t.setName("Old SSL executor thread - " + threadId.incrementAndGet() );
                    t.setDaemon( true );
                    return t;
                }
            };
            eventExecutor.setThreadFactory( newThreadFactory );
            eventExecutor.setCorePoolSize(eventThreads + 1);
            eventExecutor.setMaximumPoolSize(eventThreads + 1);
            eventExecutor.setKeepAliveTime(60, TimeUnit.SECONDS);

            sslSocketAcceptor.getDefaultConfig().setThreadModel(ThreadModel.MANUAL);
            // Add the XMPP codec filter
            sslSocketAcceptor.getFilterChain().addFirst("xmpp", new ProtocolCodecFilter(new XMPPCodecFactory()));
            sslSocketAcceptor.getFilterChain().addFirst("threadModel", executorFilter);
            // Kill sessions whose outgoing queues keep growing and fail to send traffic
            sslSocketAcceptor.getFilterChain().addAfter("xmpp", "outCap", new StalledSessionsFilter());

            // Add the SSL filter now since sockets are "borned" encrypted in the old ssl method
            SSLContext sslContext = SSLContext.getInstance(algorithm);
            KeyManagerFactory keyFactory = KeyManagerFactory.getInstance(KeyManagerFactory.getDefaultAlgorithm());
            keyFactory.init(SSLConfig.getKeyStore(), SSLConfig.getKeyPassword().toCharArray());
            TrustManagerFactory trustFactory = TrustManagerFactory.getInstance(TrustManagerFactory.getDefaultAlgorithm());
            trustFactory.init(SSLConfig.getc2sTrustStore());

            sslContext.init(keyFactory.getKeyManagers(),
                    trustFactory.getTrustManagers(),
                    new java.security.SecureRandom());

            SSLFilter sslFilter = new SSLFilter(sslContext);
            if (JiveGlobals.getProperty("xmpp.client.cert.policy","disabled").equals("needed")) {
                sslFilter.setNeedClientAuth(true);
            }
            else if(JiveGlobals.getProperty("xmpp.client.cert.policy","disabled").equals("wanted")) {
                sslFilter.setWantClientAuth(true);
            }
            sslSocketAcceptor.getFilterChain().addFirst("tls", sslFilter);

        }
        catch (Exception e) {
            System.err.println("Error starting SSL XMPP listener on port " + port + ": " +
                    e.getMessage());
            Log.error(LocaleUtils.getLocalizedString("admin.error.ssl"), e);
        }
    }
}

开发者ID:coodeer，项目名称:g3server，代码行数:69，代码来源:ConnectionManagerImpl.java

注：本文中的org.apache.mina.filter.SSLFilter类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java Document类代码示例发布时间：2022-05-23

Java Tuple4f类代码示例发布时间：2022-05-23

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18001|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9581|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8132|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8516|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8420|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9318|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8382|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7815|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8370|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7366|2022-11-06

客服电话

电子邮件

Java SSLFilter类代码示例

示例1: write

示例2: getLocalCertificates

示例3: getPeerCertificates

示例4: sessionCreated

示例5: CougarProtocol

示例6: CougarProtocol4

示例7: CougarProtocol3

示例8: secureClientSupportsTlsNoClientAuthTruststoreProvided

示例9: secureClientSupportsTlsNoClientAuthTruststoreProvidedSpecifiedCiphers

示例10: secureClientSupportsTlsWantsClientAuthTruststoreProvidedKeystoreProvided

示例11: secureClientSupportsTlsNeedsClientAuthTruststoreProvidedKeystoreProvided

示例12: secureClientRequiresTlsNoClientAuthTruststoreProvided

示例13: secureServerSupportsTlsNoClientAuthKeystoreProvided

示例14: secureServerSupportsTlsNoClientAuthKeystoreProvidedSpecifiedCiphers

示例15: secureServerSupportsTlsWantsClientAuthKeystoreProvidedTruststoreProvided

示例16: secureServerSupportsTlsNeedsClientAuthKeystoreProvidedTruststoreProvided

示例17: secureServerRequiresTlsNoClientAuthKeystoreProvided

示例18: connectFederationTLS

示例19: createTLSConfig

示例20: createClientSSLListeners

请发表评论

全部评论

上一篇：

下一篇：

CVE-2022-35343

librespeed/speedtest: Self-hosted Speedt

avehtari/BDA_m_demos: Bayesian Data Anal

四维彩超怎么看性别？四维看男孩女孩诀窍

medfreeman/markdown-it-toc-and-anchor: m

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053