0

当我使用发布者(WSO2 数据分析服务器)发布数据时出现以下错误。代码运行良好。但发布者不会将任何数据推送到服务器,我的 192.168.##.##:7711,7611 端口也处于活动状态。可以一些请帮帮我。

root@musni-hp:/opt/wso2publisher/LogDirectoryPublisher/binary# ./runlogpublisher.sh &
            [3] 10921
            root@musni-hp:/opt/wso2publisher/LogDirectoryPublisher/binary# .
             INFO [main] (LogFileDataPublisher.java:146) - Total number of files to process 2
             INFO [main] (LogFileDataPublisher.java:150) - Current file being processed 1 File Name 16063004000005_team_cdr.log
             INFO [main] (LogFileDataPublisher.java:176) - Total events: [116]
             INFO [main] (LogFileDataPublisher.java:150) - Current file being processed 2 File Name 16063005000006_team_cdr.log
             INFO [main] (LogFileDataPublisher.java:176) - Total events: [529]
            ERROR [DataBridge-ConnectionService-tcp://192.168.##.##:7611-pool-4-thread-1] (DataEndpointConnectionWorker.java:99) - Error while trying to connect to ssl://192.168.##.##:7711
            org.wso2.carbon.databridge.agent.exception.DataEndpointSecurityException: Error while trying to connect to ssl://192.168.##.##:7711
                at org.wso2.carbon.databridge.agent.endpoint.thrift.ThriftSecureClientPoolFactory.createClient(ThriftSecureClientPoolFactory.java:61)
                at org.wso2.carbon.databridge.agent.client.AbstractClientPoolFactory.makeObject(AbstractClientPoolFactory.java:37)
                at org.apache.commons.pool.impl.GenericKeyedObjectPool.borrowObject(GenericKeyedObjectPool.java:1212)
                at org.wso2.carbon.databridge.agent.endpoint.DataEndpointConnectionWorker.connect(DataEndpointConnectionWorker.java:92)
                at org.wso2.carbon.databridge.agent.endpoint.DataEndpointConnectionWorker.run(DataEndpointConnectionWorker.java:43)
                at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
                at java.util.concurrent.FutureTask.run(FutureTask.java:266)
                at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
                at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
                at java.lang.Thread.run(Thread.java:745)
            Caused by: org.apache.thrift.transport.TTransportException: Could not connect to 192.168.##.## on port 7711
                at org.apache.thrift.transport.TSSLTransportFactory.createClient(TSSLTransportFactory.java:212)
                at org.apache.thrift.transport.TSSLTransportFactory.getClientSocket(TSSLTransportFactory.java:166)
                at org.wso2.carbon.databridge.agent.endpoint.thrift.ThriftSecureClientPoolFactory.createClient(ThriftSecureClientPoolFactory.java:56)
                ... 9 more
            Caused by: java.net.ConnectException: Connection refused
                at java.net.PlainSocketImpl.socketConnect(Native Method)
                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.SocksSocketImpl.connect(SocksSocketImpl.java:392)
                at java.net.Socket.connect(Socket.java:589)
                at sun.security.ssl.SSLSocketImpl.connect(SSLSocketImpl.java:668)
                at sun.security.ssl.SSLSocketImpl.<init>(SSLSocketImpl.java:427)
                at sun.security.ssl.SSLSocketFactoryImpl.createSocket(SSLSocketFactoryImpl.java:88)
                at org.apache.thrift.transport.TSSLTransportFactory.createClient(TSSLTransportFactory.java:208)
                ... 11 more
            ERROR [DataBridge-ConnectionService-tcp://192.168.2.18:7611-pool-4-thread-1] (DataEndpointConnectionWorker.java:46) - Error while trying to connect to the endpoint. Cannot borrow client for ssl://192.168.##.##:7711
            org.wso2.carbon.databridge.agent.exception.DataEndpointAuthenticationException: Cannot borrow client for ssl://192.168.##.##:7711
                at org.wso2.carbon.databridge.agent.endpoint.DataEndpointConnectionWorker.connect(DataEndpointConnectionWorker.java:100)
                at org.wso2.carbon.databridge.agent.endpoint.DataEndpointConnectionWorker.run(DataEndpointConnectionWorker.java:43)
                at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
                at java.util.concurrent.FutureTask.run(FutureTask.java:266)
                at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
                at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
                at java.lang.Thread.run(Thread.java:745)
            Caused by: org.wso2.carbon.databridge.agent.exception.DataEndpointSecurityException: Error while trying to connect to ssl://192.168.##.##:7711
                at org.wso2.carbon.databridge.agent.endpoint.thrift.ThriftSecureClientPoolFactory.createClient(ThriftSecureClientPoolFactory.java:61)
                at org.wso2.carbon.databridge.agent.client.AbstractClientPoolFactory.makeObject(AbstractClientPoolFactory.java:37)
                at org.apache.commons.pool.impl.GenericKeyedObjectPool.borrowObject(GenericKeyedObjectPool.java:1212)
                at org.wso2.carbon.databridge.agent.endpoint.DataEndpointConnectionWorker.connect(DataEndpointConnectionWorker.java:92)
                ... 6 more
            Caused by: org.apache.thrift.transport.TTransportException: Could not connect to 192.168.##.## on port 7711
                at org.apache.thrift.transport.TSSLTransportFactory.createClient(TSSLTransportFactory.java:212)
                at org.apache.thrift.transport.TSSLTransportFactory.getClientSocket(TSSLTransportFactory.java:166)
                at org.wso2.carbon.databridge.agent.endpoint.thrift.ThriftSecureClientPoolFactory.createClient(ThriftSecureClientPoolFactory.java:56)
                ... 9 more
            Caused by: java.net.ConnectException: Connection refused
                at java.net.PlainSocketImpl.socketConnect(Native Method)
                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.SocksSocketImpl.connect(SocksSocketImpl.java:392)
                at java.net.Socket.connect(Socket.java:589)
                at sun.security.ssl.SSLSocketImpl.connect(SSLSocketImpl.java:668)
                at sun.security.ssl.SSLSocketImpl.<init>(SSLSocketImpl.java:427)
                at sun.security.ssl.SSLSocketFactoryImpl.createSocket(SSLSocketFactoryImpl.java:88)
                at org.apache.thrift.transport.TSSLTransportFactory.createClient(TSSLTransportFactory.java:208)
                ... 11 more
             INFO [DataBridge-ReconnectionService-pool-1-thread-1] (DataEndpointGroup.java:333) - No receiver is reachable at reconnection, will try to reconnect every 30 sec

屏幕截图: telnet 和 Shellscript 可以很好地读取日志文件

runlogpublisher.sh - 我们正在使用的 shellscript、properties 文件和 keystone 的内部

4

0 回答 0