olegk wrote:
>
>> Hi Oleg,
>> Yes, I have implemented my SocksSSLSocketFactory who has implemented the
>> SocketFatory interface, as the code I pasted.
>> In the debug mode, I also found this class was used by HttpClient, and
>> the
>> function createSocket and connectSocket of the SocksSSLSocketFactory were
>> calle, everything is ok before return from connectSocket: the normal
>> socket
>> has been created and conneted to proxy server, the socks4 protocol
>> finished
>> successfully, the sslsocket is created using this normal socket
>> successfully, but after return this sslsocket from connectSocket, the
>> error
>> happens, from the log I found that this sslsocket was shutdown, I don't
>> know
>> why, I don't know what happend after connectSocket returned the
>> sslsocket.
>> So my problem is that the sslsocket I created was shutdown after I
>> returned
>> it to HttpClient in connectSocket function.
>>
>>
>> 10-07-05 10:57:42,269 DEBUG -Get connection for route
>> HttpRoute[{}->https://10.64.69.13:9000]
>> [org.apache.http.impl.conn.SingleClientConnManager.getConnection(SingleClientConnManager.java:195)]
>>
>> 2010-07-05 10:57:42,269 DEBUG -Get connection for route
>> HttpRoute[{}->https://10.64.69.13:9000]
>> [org.apache.http.impl.conn.SingleClientConnManager.getConnection(SingleClientConnManager.java:195)]
>>
>> 2010-07-05 10:57:42,286 DEBUG -Connection shut down
>> [org.apache.http.impl.conn.DefaultClientConnection.shutdown(DefaultClientConnection.java:141)]
>>
>> 2010-07-05 10:57:42,286 DEBUG -Connection shut down
>> [org.apache.http.impl.conn.DefaultClientConnection.shutdown(DefaultClientConnection.java:141)]
>>
>> 2010-07-05 10:57:42,287 DEBUG -Releasing connection
>> org.apache.http.impl.conn.singleclientconnmanager$connadap...@19ab6f6
>> [org.apache.http.impl.conn.SingleClientConnManager.releaseConnection(SingleClientConnManager.java:250)]
>>
>> 2010-07-05 10:57:42,287 DEBUG -Releasing connection
>> org.apache.http.impl.conn.singleclientconnmanager$connadap...@19ab6f6
>> [org.apache.http.impl.conn.SingleClientConnManager.releaseConnection(SingleClientConnManager.java:250)]
>>
>> 2010-07-05 10:57:42,287 ERROR
>> -executeRequest=============================:class:class
>> java.net.SocketException:Socket is not connected
>> [com.trendmicro.imss.ui.modelobjects.prefilter.client.CommonUtils.executeRequest(CommonUtils.java:641)]
>>
>>
>
> Post code of the SocketFactory implementation.
>
> Oleg
>
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: [email protected]
> For additional commands, e-mail: [email protected]
>
>
>
Hi Oleg,
Here is the class which implemented SocketFactory:
public class SocksSSLSocketFactory implements SocketFactory {
private String proxyHost;
private int proxyPort;
private String userName;
private String passWd;
private final javax.net.ssl.SSLSocketFactory socketfactory;
public SocksSSLSocketFactory(SSLContext sslContext, String socksHost,
int socksPort) {
this(sslContext, socksHost, socksPort, null, null);
}
public SocksSSLSocketFactory(SSLContext sslContext, String socksHost,
int socksPort,
String userName, String passWd) {
this.socketfactory = sslContext.getSocketFactory();
proxyHost = socksHost;
proxyPort = socksPort;
this.userName = userName;
this.passWd = passWd;
}
public Socket createSocket() throws IOException {
return (SSLSocket) this.socketfactory.createSocket();
}
public Socket connectSocket(Socket sock,
String host,
int port,
InetAddress localAddress,
int localPort,
HttpParams params) throws IOException, UnknownHostException,
ConnectTimeoutException {
if (host == null) {
throw new IllegalArgumentException("Target host may not be
null.");
}
if (params == null) {
throw new IllegalArgumentException("Parameters may not be
null.");
}
InetSocketAddress epoint = new InetSocketAddress(host, port);
sock = getSocketConnected(epoint);
SSLSocket sslSocket =
(SSLSocket)this.socketfactory.createSocket(sock, host, port, false);
if ((localAddress != null) || (localPort > 0)) {
// we need to bind explicitly
if (localPort < 0) {
localPort = 0; // indicates "any"
}
InetSocketAddress isa =
new InetSocketAddress(localAddress, localPort);
sslSocket.bind(isa);
}
return sslSocket;
}
public boolean isSecure(Socket sock) throws IllegalArgumentException {
if (sock == null) {
throw new IllegalArgumentException("Socket may not be null.");
}
// This check is performed last since it calls a method implemented
// by the argument object. getClass() is final in java.lang.Object.
if (sock.isClosed()) {
throw new IllegalArgumentException("Socket is closed.");
}
return false;
}
//generate the socket connected to socks4 proxy server
private Socket getSocketConnected(InetSocketAddress endpoint) throws
IOException {
Socket socket = new Socket(proxyHost, proxyPort);
InputStream in = socket.getInputStream();
OutputStream out = socket.getOutputStream();
out.write(4);
out.write(1);
out.write((endpoint.getPort() >> 8) & 0xff);
out.write((endpoint.getPort() >> 0) & 0xff);
out.write(endpoint.getAddress().getAddress());
if (userName != null)
{
try {
out.write(userName.getBytes("ISO-8859-1"));
} catch (java.io.UnsupportedEncodingException uee) {
assert false;
}
}
out.write(0);
out.flush();
byte[] data = new byte[8];
int n = readSocketReply(in, data);
if (n != 8) {
throw new SocketException("Reply from SOCKS server has bad
length: " + n);
}
if (data[0] != 0 && data[0] != 4) {
throw new SocketException("Reply from SOCKS server has bad
version");
}
SocketException ex = null;
switch (data[1]) {
case 90:
// Success!
break;
case 91:
ex = new SocketException("SOCKS request rejected");
break;
case 92:
ex = new SocketException("SOCKS server couldn't reach
destination");
break;
case 93:
ex = new SocketException("SOCKS authentication failed");
break;
default:
ex = new SocketException("Reply from SOCKS server contains
bad status");
break;
}
if (ex != null) {
in.close();
out.close();
throw ex;
}
return socket;
}
private int readSocketReply(InputStream in, byte[] data) throws
IOException {
int len = data.length;
int received = 0;
for (int attempts = 0; received < len && attempts < 3; attempts++) {
int count = in.read(data, received, len - received);
if (count < 0)
throw new SocketException("Malformed reply from SOCKS
server");
received += count;
}
return received;
}
}
--
View this message in context:
http://old.nabble.com/How-to-use-httpclient4.0-to-connect-HTTPS-via-socks-proxy--tp29070494p29095690.html
Sent from the HttpClient-User mailing list archive at Nabble.com.
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
