当前位置 : 主页 > 大数据 > 区块链 >

py4j.protocol.Py4JNetworkError:尝试连接到Java服务器时发生错误

来源:互联网 收集:自由互联 发布时间:2021-06-22
我在py4j文档中有以下简单示例: from py4j.java_gateway import JavaGatewaydef main(): print("Hello") gateway = JavaGateway() # connect to the JVM random = gateway.jvm.java.util.Random() # create a java.util.Random instance number
我在py4j文档中有以下简单示例:

from py4j.java_gateway import JavaGateway

def main():

    print("Hello")
    gateway = JavaGateway()                   # connect to the JVM
    random = gateway.jvm.java.util.Random()   # create a java.util.Random instance
    number1 = random.nextInt(10)              # call the Random.nextInt method
    number2 = random.nextInt(10)
    print(number1,number2)

if __name__ == '__main__':
    main()

我试图运行它,但得到以下错误:

Traceback (most recent call last):
  File "/Users/edamameQ/github/myTest/main.py", line 16, in <module>
    main()
  File "/Users/edamameQ/github/myTest/main.py", line 7, in main
    random = gateway.jvm.java.util.Random()   # create a java.util.Random instance
  File "/Library/Python/2.7/site-packages/py4j/java_gateway.py", line 1188, in __getattr__
    "\n" + proto.END_COMMAND_PART)
  File "/Library/Python/2.7/site-packages/py4j/java_gateway.py", line 624, in send_command
    connection = self._get_connection()
  File "/Library/Python/2.7/site-packages/py4j/java_gateway.py", line 579, in _get_connection
    connection = self._create_connection()
  File "/Library/Python/2.7/site-packages/py4j/java_gateway.py", line 585, in _create_connection
    connection.start()
  File "/Library/Python/2.7/site-packages/py4j/java_gateway.py", line 697, in start
    raise Py4JNetworkError(msg, e)
py4j.protocol.Py4JNetworkError: An error occurred while trying to connect to the Java server

为了连接到Java服务器,我应该做些什么?谢谢!

实际上我需要单独启动JavaGateway.即,首先运行以下Java应用程序,然后python将工作.

import py4j.GatewayServer;

public class myTest {

    public static void main(String[] args) {
        myTest app = new myTest();
        // app is now the gateway.entry_point
        GatewayServer server = new GatewayServer(app);
        server.start();
    }
}
网友评论