SocketFactoryDinamico Usando Proxy [RESOLVIDO]

JavaC Membro Membro desde: 08/05/2013 11:49:56 Mensagens: 6 Offline

Boa noite, na empresa que trabalho utilizamos firewall e o proxy bloqueava as conexões com o servidor da Sefaz, depois de muito pesquisar encontrei a solução alterando a classe SocketFactoryDinamico utilizando a classe SSLTunnelSocketFactory, tentei alterar o proxy da VM e não funcionava, essa foi a solução que serviu pra mim, como já encontrei muita coisa que precisei no fórum, estou postando as classes para quem precisar.

Renato,

Obrigado pela contribuição, certamente ajudará muitos membros do fórum.

JavaC Membro Membro desde: 31/12/2011 13:53:46 Mensagens: 101 Offline

Irei realmente utilizar,

obrigado ... testes iniciando

JavaC Membro Membro desde: 31/12/2011 13:53:46 Mensagens: 101 Offline

Bom dia,

Não consegui utilizar essa classe para envio por proxy,
no local onde testei não existe solicitação de Usuario e Senha
apenas IP e Porta do proxy, com isso gera um monte de exceções.
Se puder dar uma mão nessa parte

JavaC Membro Membro desde: 08/05/2013 11:49:56 Mensagens: 6 Offline

Teria como enviar as exceções?

JavaC Membro Membro desde: 31/12/2011 13:53:46 Mensagens: 101 Offline

Consegui resolver amigo, obrigado pela atenção

em caso de não ter usuário não faço o passwordAuthentication();

JavaC Membro Membro desde: 18/08/2015 09:56:15 Mensagens: 98 Offline

Amigos quando executo a classe:

package br.com.nfe;

import br.com.nfe.SSLTunnelSocketFactory;
import java.io.FileInputStream;
import java.io.IOException;
import java.net.*;
import java.security.*;
import java.security.cert.CertificateException;
import java.security.cert.X509Certificate;
import java.util.Enumeration;
import javax.net.SocketFactory;
import javax.net.ssl.*;
import org.apache.commons.httpclient.ConnectTimeoutException;
import org.apache.commons.httpclient.params.HttpConnectionParams;
import org.apache.commons.httpclient.protocol.Protocol;
import org.apache.commons.httpclient.protocol.ProtocolSocketFactory;

public class SocketFactoryDinamico implements ProtocolSocketFactory {

private static boolean isLoaded;    
    private SSLContext ssl = null;
    private X509Certificate certificate;
    private PrivateKey privateKey;
    private String fileCacerts;

public SocketFactoryDinamico(X509Certificate certificate,
            PrivateKey privateKey) {
        this.certificate = certificate;
        this.privateKey = privateKey;
    }

public static void reload() {
        SocketFactoryDinamico.isLoaded = false;
    }

public static void load(KeyStore ks, char[] pin, String patOfCacerts)
            throws KeyStoreException, UnrecoverableKeyException, NoSuchAlgorithmException {
        load(ks, null, pin, patOfCacerts);
    }

public static void load(KeyStore ks, String alias, char[] pin, String patOfCacerts)
            throws KeyStoreException, UnrecoverableKeyException, NoSuchAlgorithmException {
        if (!isLoaded) {
            if ((alias == null) || ("".equals(alias))) {
                Enumeration<String> aliasesEnum = ks.aliases();
                while (aliasesEnum.hasMoreElements()) {
                    alias = (String) aliasesEnum.nextElement();
                    if (ks.isKeyEntry(alias)) {
                        break;
                    }
                }
            }

X509Certificate certificate = (X509Certificate) ks.getCertificate(alias);
            PrivateKey privateKey = (PrivateKey) ks.getKey(alias, pin);
            SocketFactoryDinamico socketFactoryDinamico = new SocketFactoryDinamico(certificate, privateKey);
            socketFactoryDinamico.setFileCacerts(patOfCacerts);

Protocol protocol = new Protocol("https", socketFactoryDinamico, 433);
            Protocol.registerProtocol("https", protocol);

isLoaded = true;
        }
    }

private SSLContext createSSLContext() {
        try {
            KeyManager[] keyManagers = createKeyManagers();
            TrustManager[] trustManagers = createTrustManagers();
            SSLContext sslContext = SSLContext.getInstance("TLS");
            sslContext.init(keyManagers, trustManagers, null);

return sslContext;
        } catch (KeyManagementException e) {
            error(e.toString());
        } catch (KeyStoreException e) {
            error(e.toString());
        } catch (NoSuchAlgorithmException e) {
            error(e.toString());
        } catch (CertificateException e) {
            error(e.toString());
        } catch (IOException e) {
            error(e.toString());
        }
        return null;
    }

private SSLContext getSSLContext() {
        if (ssl == null) {
            ssl = createSSLContext();
        }
        return ssl;
    }

public Socket createSocket(String host, int port, InetAddress localAddress,
            int localPort, HttpConnectionParams params) throws IOException,
            UnknownHostException, ConnectTimeoutException {
        if (params == null) {
            throw new IllegalArgumentException("Parameters may not be null");
        }
        
        if (2>1) {
            String proxyServ = System.getProperty("cte.proxy.host");
            String proxyPort = System.getProperty("cte.proxy.port");
            String proxyUser = System.getProperty("cte.proxy.user");            
            String proxyPass = System.getProperty("cte.proxy.pass");  
            SSLTunnelSocketFactory socketfactory = new SSLTunnelSocketFactory(proxyServ, proxyPort, getSSLContext());            
            Socket socket = socketfactory.createSocket(host, port, new PasswordAuthentication(proxyUser, proxyPass.toCharArray()));   
            return socket;            
        }
        
        int timeout = params.getConnectionTimeout();
        SocketFactory socketfactory = getSSLContext().getSocketFactory();
        if (timeout == 0) {
            return socketfactory.createSocket(host, port, localAddress,
                    localPort);
        }

Socket socket = socketfactory.createSocket();
        SocketAddress localaddr = new InetSocketAddress(localAddress, localPort);
        SocketAddress remoteaddr = new InetSocketAddress(host, port);
        socket.bind(localaddr);
        try {
            socket.connect(remoteaddr, timeout);
        } catch (Exception e) {
            error(e.toString());
            throw new ConnectTimeoutException("Possível timeout de conexão", e);
        }

return socket;
    }

public Socket createSocket(String host, int port, InetAddress clientHost,
            int clientPort) throws IOException, UnknownHostException {
        return getSSLContext().getSocketFactory().createSocket(host, port,
                clientHost, clientPort);
    }

public Socket createSocket(String host, int port) throws IOException,
            UnknownHostException {
        return getSSLContext().getSocketFactory().createSocket(host, port);
    }

public Socket createSocket(Socket socket, String host, int port,
            boolean autoClose) throws IOException, UnknownHostException {
        return getSSLContext().getSocketFactory().createSocket(socket, host,
                port, autoClose);
    }

public KeyManager[] createKeyManagers() {
        HSKeyManager keyManager = new HSKeyManager(certificate, privateKey);

return new KeyManager[]{keyManager};
    }

public TrustManager[] createTrustManagers() throws KeyStoreException,
            NoSuchAlgorithmException, CertificateException, IOException {
        KeyStore trustStore = KeyStore.getInstance("JKS");

trustStore.load(new FileInputStream(fileCacerts), "changeit".toCharArray());
        TrustManagerFactory trustManagerFactory = TrustManagerFactory
                .getInstance(TrustManagerFactory.getDefaultAlgorithm());
        trustManagerFactory.init(trustStore);
        return trustManagerFactory.getTrustManagers();
    }

class HSKeyManager implements X509KeyManager {

private X509Certificate certificate;
        private PrivateKey privateKey;

public HSKeyManager(X509Certificate certificate, PrivateKey privateKey) {
            this.certificate = certificate;
            this.privateKey = privateKey;
        }

public String chooseClientAlias(String[] arg0, Principal[] arg1,
                Socket arg2) {
            return certificate.getIssuerDN().getName();
        }

public String chooseServerAlias(String arg0, Principal[] arg1,
                Socket arg2) {
            return null;
        }

public X509Certificate[] getCertificateChain(String arg0) {
            return new X509Certificate[]{certificate};
        }

public String[] getClientAliases(String arg0, Principal[] arg1) {
            return new String[]{certificate.getIssuerDN().getName()};
        }

public PrivateKey getPrivateKey(String arg0) {
            return privateKey;
        }

public String[] getServerAliases(String arg0, Principal[] arg1) {
            return null;
        }
    }

public void setFileCacerts(String fileCacerts) {
        this.fileCacerts = fileCacerts;
    }

/**
     * Log Error.
     *
     * @param log
     */
    private static void error(String log) {
        System.out.println("ERROR: " + log);
    }
}

me retorna esse exception

log4j:WARN No appenders could be found for logger (org.apache.axiom.om.util.StAXUtils).
log4j:WARN Please initialize the log4j system properly.
ERROR: java.net.ConnectException: Connection timed out: connect
Exception in thread "main" org.apache.axis2.AxisFault: Possível timeout de conexão
	at org.apache.axis2.AxisFault.makeFault(AxisFault.java:430)
	at org.apache.axis2.transport.http.HTTPSender.sendViaPost(HTTPSender.java:197)
	at org.apache.axis2.transport.http.HTTPSender.send(HTTPSender.java:75)
	at org.apache.axis2.transport.http.CommonsHTTPTransportSender.writeMessageWithCommons(CommonsHTTPTransportSender.java:404)
	at org.apache.axis2.transport.http.CommonsHTTPTransportSender.invoke(CommonsHTTPTransportSender.java:231)
	at org.apache.axis2.engine.AxisEngine.send(AxisEngine.java:443)
	at org.apache.axis2.description.OutInAxisOperationClient.send(OutInAxisOperation.java:406)
	at org.apache.axis2.description.OutInAxisOperationClient.executeImpl(OutInAxisOperation.java:229)
	at org.apache.axis2.client.OperationClient.execute(OperationClient.java:165)
	at br.inf.portalfiscal.www.nfe.wsdl.nfedownloadnf.NfeDownloadNFStub.nfeDownloadNF(NfeDownloadNFStub.java:180)
	at br.com.nfe.DownloadNFe.execute(DownloadNFe.java:89)
	at br.com.nfe.DownloadNFe.main(DownloadNFe.java:29)
Caused by: org.apache.commons.httpclient.ConnectTimeoutException: Possível timeout de conexão
	at br.com.nfe.SocketFactoryDinamico.createSocket(SocketFactoryDinamico.java:92)
	at org.apache.commons.httpclient.HttpConnection.open(HttpConnection.java:707)
	at org.apache.commons.httpclient.MultiThreadedHttpConnectionManager$HttpConnectionAdapter.open(MultiThreadedHttpConnectionManager.java:1361)
	at org.apache.commons.httpclient.HttpMethodDirector.executeWithRetry(HttpMethodDirector.java:387)
	at org.apache.commons.httpclient.HttpMethodDirector.executeMethod(HttpMethodDirector.java:171)
	at org.apache.commons.httpclient.HttpClient.executeMethod(HttpClient.java:397)
	at org.apache.axis2.transport.http.AbstractHTTPSender.executeMethod(AbstractHTTPSender.java:621)
	at org.apache.axis2.transport.http.HTTPSender.sendViaPost(HTTPSender.java:193)
	... 10 more
Caused by: java.net.ConnectException: Connection timed out: connect
	at java.net.DualStackPlainSocketImpl.waitForConnect(Native Method)
	at java.net.DualStackPlainSocketImpl.socketConnect(Unknown Source)
	at java.net.AbstractPlainSocketImpl.doConnect(Unknown Source)
	at java.net.AbstractPlainSocketImpl.connectToAddress(Unknown Source)
	at java.net.AbstractPlainSocketImpl.connect(Unknown Source)
	at java.net.PlainSocketImpl.connect(Unknown Source)
	at java.net.SocksSocketImpl.connect(Unknown Source)
	at java.net.Socket.connect(Unknown Source)
	at sun.security.ssl.SSLSocketImpl.connect(Unknown Source)
	at br.com.nfe.SocketFactoryDinamico.createSocket(SocketFactoryDinamico.java:89)
	... 17 more