java rpc接口_java调用python模型

java rpc接口_java调用python模型依赖<!–XMRPC相关依赖–><dependency><groupId>org.apache.xmlrpc</groupId><artifactId>xmlrpc-server</artifactId><version>3.1.3</version></dependency>

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE稳定放心使用

依赖

<!--XMRPC相关依赖-->
        <dependency>
            <groupId>org.apache.xmlrpc</groupId>
            <artifactId>xmlrpc-server</artifactId>
            <version>3.1.3</version>
        </dependency>
        <dependency>
            <groupId>org.apache.xmlrpc</groupId>
            <artifactId>xmlrpc-client</artifactId>
            <version>3.1.3</version>
        </dependency>
        <!--httpclient(此依赖是配置接口连接超时时间所需的)-->
        <dependency>
            <groupId>org.apache.httpcomponents</groupId>
            <artifactId>httpclient</artifactId>
            <version>4.5.3</version>
        </dependency>
        <dependency>
            <groupId>org.apache.httpcomponents</groupId>
            <artifactId>httpcore</artifactId>
            <version>4.4.1</version>
        </dependency>
        <dependency>
            <groupId>commons-httpclient</groupId>
            <artifactId>commons-httpclient</artifactId>
            <version>3.1</version>
        </dependency>

java代码


import org.apache.xmlrpc.XmlRpcException;
import org.apache.xmlrpc.client.XmlRpcClient;
import org.apache.xmlrpc.client.XmlRpcClientConfigImpl;
import org.apache.xmlrpc.client.XmlRpcCommonsTransportFactory;

import java.net.URL;

public class RpcTest {
    public static void main(String[] args) throws Exception {
        XmlRpcClientConfigImpl config = new XmlRpcClientConfigImpl();
        //服务端url后面需要加上“/RPC2”,用于声明请求是rpc协议
        config.setServerURL(new URL("http://127.0.0.1:8000/RPC2"));
        config.setEnabledForExtensions(true);
        config.setEnabledForExceptions(true);
        //配置接口连接超时时间,目前均设置为10s
        config.setConnectionTimeout(10 * 1000);
        config.setReplyTimeout(10 * 1000);
        XmlRpcClient client = new XmlRpcClient();
        client.setTransportFactory(new XmlRpcCommonsTransportFactory(client));
        client.setConfig(config);
        // 根据不同的python函数形式,构造参数
        // 求第一个数的数量相乘 参数为2则是 5*5 参数为3则是5*5*5
        Object[] params1 = new Object[] {new Integer(5), new Integer(2)};

        // 单个字符串参数
        Object[] params2 = new Object[] {new String("aaa"), new String("bbb")};

        // 无参数
        //Object[] params = null;
        try {
            Object pow = client.execute("pow", params1);
            System.err.println(pow);
            //返回的结果是字符串类型,强制转换res为String类型
            //其中“add”为rpc接口名,params2为接口所需参数 如果是字符串则拼接
            Object res2 =  client.execute("add", params2);
            System.err.println(res2);
            //其中“add”为rpc接口名,params1为接口所需参数 如果是int类型则相加
            Object res3 = client.execute("add", params1);
            System.err.println(res3);
        } catch (XmlRpcException e) {
            e.printStackTrace();
        }
    }
}

windows安装python环境并使用:https://www.cnblogs.com/jxuan/p/14849020.html

python代码

打开IDLE程序后点击左上角File–New File
在这里插入图片描述
复制下面python代码之后保存下来
保存之后点击run– Run Moudle
在这里插入图片描述

python代码

from xmlrpc.server import SimpleXMLRPCServer
from xmlrpc.server import SimpleXMLRPCRequestHandler
import time

# Restrict to a particular path.
class RequestHandler(SimpleXMLRPCRequestHandler):
    rpc_paths = ('/RPC2',)


# Create server
server = SimpleXMLRPCServer(("127.0.0.1", 8000),
                            requestHandler=RequestHandler)
server.register_introspection_functions()

# Register pow() function; this will use the value of
# pow.__name__ as the name, which is just 'pow'.
server.register_function(pow)


# Register a function under a different name
def adder_function(x, y):
    #time.sleep(30)
    return x + y


server.register_function(adder_function, 'add')


# Register an instance; all the methods of the instance are
# published as XML-RPC methods (in this case, just 'div').
class MyFuncs:
    def div(self, x, y):
        return x // y


server.register_instance(MyFuncs())

# Run the server's main loop
server.serve_forever()

运行

运行之后重新打开IDLE程序
一行一行的复制并回车

import xmlrpc.client
server = xmlrpc.client.ServerProxy("http://127.0.0.1:8000")
print(server.pow(5, 2))
print(server.add("AAA", "520"))
server.add(22, 33)

在这里插入图片描述

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/182607.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • IIS无法启动:发生意外错误0x8ffe2740的原因

    IIS无法启动:发生意外错误0x8ffe2740的原因原因如果系统中存在端口冲突就有可能发生本情况. IIS默认使用80端口进行HTTP通信. 如果除IIS外的应用程序正在运行并且正在相同的IP地址上使用80端口,在您试图使用IIS管理器启动网站时您也可能收到该错误讯息. 解决方法要解决这个问题,您可以进行以下任一项操作:• 在IIS管理器中更改网站绑定端口为除80端口外的其它端口. • 停止正在使用80端口的应

  • Java经典算法(二)

    Java经典算法(二)【程序10】题目:将一个正整数分解质因数。例如:输入90,打印出90=233*5。程序分析:对n进行分解质因数,应先找到一个最小的质数k,然后按下述步骤完成:(1)如果这个质数恰等于n,则说明分解质因数的过程已经结束,打印出即可。(2)如果n!=k,但n能被k整除,则应打印出k的值,并用n除以k的商,作为新的正整数你n,重复执行第一步。(3)如果n不能被k整除,则用k+1作为k的值,重复执行第一步。解题代码:importjava.util.Scanner;publicclassTe

  • Linux#使用ll命令

    Linux#使用ll命令     ubuntu和mac环境下,没有ll命令,对于习惯在Linux环境使用ll命令的开发人员来说,着实不便。     介绍两种添加ll命令的方法:     一、设置别名        1、编辑~/.bashrc mac环境为~./bash_profile             sudovim~/.bash_profile        2、…

  • spring spel表达式_Substring

    spring spel表达式_Substring1.什么是SpEL表达式SpEL表达式语言是一种表达式语言,是一种可以与一个基于spring的应用程序中的运行时对象交互的东西。有点类似于ognl表达式。总得来说SpEL表达式是一种简化开发的表达式,通过使用表达式来简化开发,减少一些逻辑、配置的编写。2.使用XML方式实现SpEL表达式

  • Feign原理 (图解)_feign原理

    Feign原理 (图解)_feign原理1.1简介:Feign远程调用的Feign远程调用,核心就是通过一系列的封装和处理,将以JAVA注解的方式定义的远程调用API接口,最终转换成HTTP的请求形式,然后将HTTP的请求的响应结果,解码成JAVABean,放回给调用者。Feign远程调用的基本流程,大致如下图所示。从上图可以看到,Feign通过处理注解,将请求模板化,当实际调用的时候,传入参数,根据参数再应用到请求上,进而转化成真正的Request请求。通过Feign以及JAVA的动态代理机制,使得Java…

  • windows django安装

    windows django安装

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号