dubbo远程调用接口

时间:2025-03-19 08:57:27

最近做了一个项目需要使用dubbo调用远程接口,写出来分享一下

首先需要提供接口的人给你接口地址,注册中心地址,以及参数类型,参数类型可以是实体类,可以让客户直接把实体类发给你

 

接口地址就是类名地址以及要调用的方法

比如:

其中是包名

ToInterService是类名

sendService是方法名

准备工作做好了就开始干吧

  1. 配置dubbo的配置文件
    <?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="/schema/beans" 
        xmlns:xsi="http:///2001/XMLSchema-instance" 
        xmlns:dubbo="/schema/dubbo" 
    	xsi:schemaLocation="/schema/beans
    	/schema/beans/
    	/schema/dubbo
    	/schema/dubbo/">
    	<!-- 描述 -->
    	<description>dubbo客户端服务配置</description>
    	<!-- 消费者系统标志 -->
    	<dubbo:application name="ACTUARY-SYSTEM"/>
    	<!-- 注册中心地址 -->
    	<dubbo:registry protocol="zookeeper" address="注册中心IP:端口号" client="zkclient"/>
    	<!-- 消费者 -->
    	<dubbo:reference  
                    interface="" 
                    url="dubbo://调用服务IP:端口号" check="false" timeout="600000"/>
    </beans>

    需要注意的是:注册中心的address,以及消费者需要调用的interface,url要正确

  2. 在本地新建类

           需要注意:本地新建类的包名,类型,以及方法要和提供的一致,可以让客户提供,自行复制粘贴即可

        

package ;

import ;

public abstract interface ToInterService
{
    public abstract String sendService(String param);
}

  3.加载

  4.测试

    @Autowired
	ToInterService toInterService;

	public void test() {
		("开始");
		String result=("aa");
		("结果=="+result);
		
	}
<dependency>
			<groupId></groupId>
			<artifactId>dubbo</artifactId>
			<version>2.8.4</version>
			<exclusions>
				<exclusion>
					<artifactId>curator-framework</artifactId>
					<groupId></groupId>
				</exclusion>
				<exclusion>
					<artifactId>curator-client</artifactId>
					<groupId></groupId>
				</exclusion>
				<exclusion>
					<artifactId>guava</artifactId>
					<groupId></groupId>
				</exclusion>
				<exclusion>
					<artifactId>spring-web</artifactId>
					<groupId></groupId>
				</exclusion>
			</exclusions>
		</dependency>
		<!-- zookeeper注册中心工具包 -->
		<dependency>
		    <groupId></groupId>
		    <artifactId>zookeeper</artifactId>
		    <version>3.4.9</version>
		</dependency>
		<dependency>
			<groupId>com.101tec</groupId>
			<artifactId>zkclient</artifactId>
			<version>0.9</version>
		</dependency>
		<!-- JunitTest依赖,仅仅junit测试使用 -->
		<dependency>
		    <groupId></groupId>
		    <artifactId>websocket-server</artifactId>
		    <version>9.2.10.v20150310</version>
		    <scope>test</scope>
		</dependency>