标签: java-client

RabbitMQ on Amazon EC2 Instance & Locally?也有人问过类似的问题 ？ 并且 无法从我的桌面连接到 ec2 上的 rabbitmq 但他们收到不同的错误消息。

我有一个 RabbitMQ 服务器在我的 linux EC2 实例上运行，它设置正确。我创建了自定义用户并授予他们读/写队列的权限。使用本地客户端，我能够正确接收消息。我已经在 EC2 上设置了安全组，以便端口 (5672/25672) 处于打开状态并且可以 telnet 到这些端口。我也像这样设置了rabbitmq.conf。

[
    {rabbit, [
            {tcp_listeners, [{"0.0.0.0",5672}]},
            {loopback_users, []},
            {log_levels, [{connection, info}]}
            ]
    }
].

目前我在服务器上有一个客户端发布到队列。

我有另一个客户端在 EC2 之外的服务器上运行，它需要使用来自同一个队列的数据（我不能在 EC2 上同时运行这两个客户端，因为消耗做了大量绘图/图形操作）。

然而，当我尝试使用一些测试代码从外部客户端连接时

try {
    ConnectionFactory factory = new ConnectionFactory();
    factory.setUri("amqp://****:****@****:5672/");
    connection = factory.newConnection();
} catch (IOException e) {
    e.printStackTrace();

}

我收到以下错误。

com.rabbitmq.client.AuthenticationFailureException: ACCESS_REFUSED - 使用 PLAIN 身份验证机制拒绝登录。有关详细信息，请参阅代理日志文件。

但是，代理日志文件中没有任何内容，就好像我从未尝试过连接一样。我试过使用工厂的各个 getter/setter 方法进行连接，我试过使用不同的端口（同时打开它们）。

我想知道我是否需要使用 SSL 或不连接到 EC2，但从网上阅读它似乎应该可以正常工作，但我不确定。我找不到任何成功实现我正在尝试做的事情并记录下来的人的例子。

提前致谢

我正在尝试使用 Stomp 和 Sockjs 创建一个独立的 Java 应用程序作为今年 Spring 的 websocket 客户端，考虑到 spring 规范和 spring-portafolio 示例，我收到此错误：

15:18:01.342 [main] DEBUG com.example.client.WebSocketClientTest - Connecting to : ws://localhost:8080/socket/hello
15:18:01.541 [WebSocketClient-AsyncIO-1] ERROR com.example.client.MyStompSessionHandler - Transport error
org.springframework.messaging.simp.stomp.ConnectionLostException: Connection closed
at org.springframework.messaging.simp.stomp.DefaultStompSession.afterConnectionClosed(DefaultStompSession.java:483) [spring-messaging-4.3.2.RELEASE.jar:4.3.2.RELEASE]
at org.springframework.web.socket.messaging.WebSocketStompClient$WebSocketTcpConnectionHandlerAdapter.afterConnectionClosed(WebSocketStompClient.java:354) [spring-websocket-4.3.2.RELEASE.jar:4.3.2.RELEASE]
at org.springframework.web.socket.sockjs.client.AbstractClientSockJsSession.afterTransportClosed(AbstractClientSockJsSession.java:321) [spring-websocket-4.3.2.RELEASE.jar:4.3.2.RELEASE]
at org.springframework.web.socket.sockjs.client.WebSocketTransport$ClientSockJsWebSocketHandler.afterConnectionClosed(WebSocketTransport.java:172) [spring-websocket-4.3.2.RELEASE.jar:4.3.2.RELEASE]
at org.springframework.web.socket.adapter.standard.StandardWebSocketHandlerAdapter.onClose(StandardWebSocketHandlerAdapter.java:141) [spring-websocket-4.3.2.RELEASE.jar:4.3.2.RELEASE]...

我在java客户端的代码是：

StandardWebSocketClient webSocketClient = new StandardWebSocketClient();
List<Transport> transports = new ArrayList<>();
transports.add(new WebSocketTransport(webSocketClient));
SockJsClient sockJsClient = new SockJsClient(transports);
ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
taskScheduler.afterPropertiesSet();
String stompUrl = "ws://localhost:8080/socket/hello";
WebSocketStompClient stompClient = …

我正在开发一个客户端Java应用程序,它具有一些功能,需要从一些以JSON传输的Web服务中获取数据(一些是RESTful,一些不是).没有JavaScript,没有Web浏览器,只是一个普通的JAR文件,它将使用Swing为GUI本地运行.

这不是一个新的或独特的问题; 肯定有一些开源库可以通过HTTP处理JSON数据传输.我已经发现了一些将解析JSON,但我找不到任何能够处理HTTP通信来使用JSON Web服务的东西.

到目前为止,我发现Apache Axis2显然可能至少有部分解决方案,但我没有看到足够的文档知道它是否能满足我的需要,或者如何使用它.也许问题的一部分是我没有Web服务的经验,所以当我看到它时,我无法知道解决方案.我希望你们中的一些人能指出我正确的方向.例子会有所帮助.

因此,在我的localmachine上使用最新版本的elasticsearch,java客户端节点,不会收到任何关于masternode的信息.并断开连接.

即使使用默认配置,我也尝试了以下代码.它仍然不起作用.

如果我使用TransportClient一切正常.

谁知道发生了什么？

Java客户端代码

Node node = nodeBuilder()
                .clusterName("Scrapper")
                .client(true)
                .data(false)
                .local(false)
                .settings(
                    Settings.builder()
                        .put("path.home", ".")
                        .put("name", "JG")
                        .put("http.enabled", false)
                        .put("node.master", false)
                        .put("discovery.zen.ping.multicast.enabled", false)
                        .put("discovery.zen.ping.unicast.hosts", "127.0.0.1:9300")
                        .put("network.host", "127.0.0.1")
                        .put("transport.tcp.port", "9301")
                )
                .node();
Client client = node.client();

System.out.println("Firing Requests.");

String INDEX = "test_index";
boolean indexExists = client.admin().indices().prepareExists(INDEX).execute().actionGet().isExists();
if (!indexExists) {
  client.admin().indices().prepareCreate(INDEX).execute().actionGet();
}

SearchResponse allHits = client.prepareSearch(INDEX)
                             .addFields("title", "category")
                             .setQuery(QueryBuilders.matchAllQuery())
                             .execute().actionGet();

System.out.println("allHits = " + allHits);

Java客户端日志:

Jan 13, 2016 12:28:50 PM org.elasticsearch.node.Node <init>
INFO: [JG] version[2.1.1], pid[33792], build[40e2c53/2015-12-15T13:05:55Z]
Jan 13, …

通过以下链接https://kubernetes.io/docs/tasks/administer-cluster/encrypt-data/描述了如何添加秘密（加密）数据。

如何从java客户端获取键值？

我有一个使用wsHttpBinding的WCF Web服务,我从Java客户端使用它.我使用wsimport从WSDL生成代码.java客户端似乎正在创建服务,但是当我在服务上调用方法时,客户端只是旋转.

MyService s = new MyService();
IMyService i = s.getWSHttpBindingIMyService();
returnedValue = i.getSomething(2); // method call

Java客户端可以与使用wsHttpBinding的WCF Web服务进行通信吗？这样做的最佳方法是什么？
任何帮助将不胜感激.

尝试了几个选项后,我无法在Android应用程序上收到所有SignalR消息.在我看来它似乎是与LongPollingTransport相关的东西,但我找不到解决方案...我收到所有的longPolling消息,但有时它进入处理程序,有时它尝试再次连接到服务器而不进入处理程序方法.

我试着按照这里的例子.

代码很简单:

public void startNewSignalR(){

    Platform.loadPlatformComponent(new AndroidPlatformComponent());

    // Create a new console logger
    Logger logger = new Logger() {
        @Override
        public void log(String message, LogLevel level) {
            System.out.println(message);
        }
    };

    Uri signalRSource = Uri.parse(serverUrl);
    HubConnection connection = new HubConnection(signalRSource.toString(), "", true, logger);
    eventHub = connection.createHubProxy("eventHub");

    connection.error(new ErrorCallback() {

        @Override
        public void onError(Throwable error) {
            System.err.println("There was an error communicating with the server.");
            System.err.println("Error detail: " + error.toString());

            error.printStackTrace(System.err);
        }
    });

    // Subscribe to the connected event
    connection.connected(new …