我有一个java(AWS java SDK 1.11.313(SQS消费者，它每20秒轮询一个队列，已经运行了近一周。在这段时间里，它已经两次失败，两次都抛出了以下异常：
com.amazonaws.SdkClientException: Unable to execute HTTP request: Permission denied: connect
at com.amazonaws.http.AmazonHttpClient$RequestExecutor.handleRetryableException(AmazonHttpClient.java:1114)
at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeHelper(AmazonHttpClient.java:1064)
at com.amazonaws.http.AmazonHttpClient$RequestExecutor.doExecute(AmazonHttpClient.java:743)
at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeWithTimer(AmazonHttpClient.java:717)
at com.amazonaws.http.AmazonHttpClient$RequestExecutor.execute(AmazonHttpClient.java:699)
at com.amazonaws.http.AmazonHttpClient$RequestExecutor.access$500(AmazonHttpClient.java:667)
at com.amazonaws.http.AmazonHttpClient$RequestExecutionBuilderImpl.execute(AmazonHttpClient.java:649)
at com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:513)
at com.amazonaws.services.sqs.AmazonSQSClient.doInvoke(AmazonSQSClient.java:2033)
at com.amazonaws.services.sqs.AmazonSQSClient.invoke(AmazonSQSClient.java:2009)
at com.amazonaws.services.sqs.AmazonSQSClient.executeReceiveMessage(AmazonSQSClient.java:1485)
at com.amazonaws.services.sqs.AmazonSQSClient.receiveMessage(AmazonSQSClient.java:1460)
at net.myCompany.messageHandlers.QMessageHandler.receiveMsg(QMessageHandler.java:112)
at net.myCompany.MessageHandler.receiveDirectMsg(MessageHandler.java:23)
at net.myCompany.commandProcessors.QCommandProcessor.run(QCommandProcessor.java:23)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.net.SocketException: Permission denied: connect
at java.net.DualStackPlainSocketImpl.connect0(Native Method)
at java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:83)
at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:172)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
at java.net.Socket.connect(Socket.java:589)
at org.apache.http.conn.ssl.SSLConnectionSocketFactory.connectSocket(SSLConnectionSocketFactory.java:339)
at com.amazonaws.http.conn.ssl.SdkTLSSocketFactory.connectSocket(SdkTLSSocketFactory.java:132)
at org.apache.http.impl.conn.DefaultHttpClientConnectionOperator.connect(DefaultHttpClientConnectionOperator.java:142)
at org.apache.http.impl.conn.PoolingHttpClientConnectionManager.connect(PoolingHttpClientConnectionManager.java:373)
at sun.reflect.GeneratedMethodAccessor21.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at com.amazonaws.http.conn.ClientConnectionManagerFactory$Handler.invoke(ClientConnectionManagerFactory.java:76)
at com.amazonaws.http.conn.$Proxy9.connect(Unknown Source)
at org.apache.http.impl.execchain.MainClientExec.establishRoute(MainClientExec.java:381)
at org.apache.http.impl.execchain.MainClientExec.execute(MainClientExec.java:237)
at org.apache.http.impl.execchain.ProtocolExec.execute(ProtocolExec.java:185)
at org.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java:185)
at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:83)
at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:56)
at com.amazonaws.http.apache.client.impl.SdkHttpClient.execute(SdkHttpClient.java:72)
at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeOneRequest(AmazonHttpClient.java:1236)
at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeHelper(AmazonHttpClient.java:1056)
... 14 more
在这两种情况下，客户端都在约15分钟后恢复。下面的方法负责创建和发送接收请求。在for循环上方的sqs.receiveMessage()方法调用上出现异常。每次发送请求时，都会创建一个新的com.amazonaws.services.sqs.AmazonSQS实例并将其分配给sqs变量。
List<JSONObject> receiveMsg() {
List<JSONObject> cmdMsgList = new ArrayList<>();
try {
if(sqs != null) {
System.out.println("Attempting message receive at: " + Instant.now());
// Receive messages
ReceiveMessageRequest receiveMessageRequest = new ReceiveMessageRequest(commandQUrl);
receiveMessageRequest.setWaitTimeSeconds(20);
receiveMessageRequest.setMaxNumberOfMessages(10);
List<Message> messages = sqs.receiveMessage(receiveMessageRequest).getMessages();
for (Message message : messages) {
JSONObject msgBody = checkTargetDevice(message);
if (msgBody != null) {
cmdMsgList.add(msgBody);
}
}
} else {
ServiceManager.getInstance().setServerConnection(false);
ServiceManager.getInstance().setConnectionStatus("Can't receive message - Message channel does not exist");
}
} catch (QueueDoesNotExistException mia) {
ServiceManager.getInstance().setServerConnection(false);
}catch (AmazonServiceException ase) {
if(ServiceManager.getInstance().isDebug()) {
ase.printStackTrace();
ase.getErrorMessage();
}
} catch (AmazonClientException ace) {
if(ServiceManager.getInstance().isDebug()) {
ace.printStackTrace();
}
}
return cmdMsgList;
}
我认为可能创建了太多的连接，但没有正确关闭。然而，在使用netstat后，该程序只有几个tcp连接，这似乎并不过分。此后，我在return语句之前添加了sqs.shutdown()调用，但我预计不会有太大变化，因为AWS文档指出，AmazonSQS接口上的此方法调用是一个可选方法，不希望调用方调用它。
我们非常感谢您对这个问题的任何见解或建议。提前谢谢。
在从aws SQS轮询数据时，我遇到了同样的非周期性问题。我添加了延迟时间来调用aws SQS，这个问题得到了解决。如下JAVA。
final ReceiveMessageRequest receiveMessageRequest =
new ReceiveMessageRequest(sqsURL)
.withMaxNumberOfMessages(1)
.withWaitTimeSeconds(6);
希望这能解决这个问题。