Apache Dubbo 是一种高性能的、轻量级的开源RPC框架,主要用于在分布式系统中提供服务。以下是一个简单的使用Dubbo的例子,展示如何定义服务接口和使用Dubbo进行远程服务调用。
- 定义服务接口:
public interface GreetingsService {
String sayHello(String name);
}
- 服务提供者实现:
public class GreetingsServiceImpl implements GreetingsService {
@Override
public String sayHello(String name) {
return "Hello, " + name + "!";
}
}
- 配置服务提供者:
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://code.alibabatech.com/schema/dubbo
http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
<dubbo:application name="demo-provider"/>
<dubbo:registry address="zookeeper://127.0.0.1:2181"/>
<dubbo:protocol name="dubbo" port="20880"/>
<dubbo:service interface="GreetingsService" ref="greetingsService" />
<bean id="greetingsService" class="GreetingsServiceImpl"/>
</beans>
- 服务消费者调用:
public class GreetingsConsumer {
public static void main(String[] args) throws Exception {
ReferenceConfig<GreetingsService> reference = new ReferenceConfig<>();
reference.setApplication(new ApplicationConfig("demo-consumer"));
reference.setRegistry(new RegistryConfig("zookeeper://127.0.0.1:2181"));
reference.setInterface(GreetingsService.class);
GreetingsService greetingsService = reference.get();
System.out.println(greetingsService.sayHello("World"));
}
}
在这个例子中,我们定义了一个简单的服务接口GreetingsService
,然后在服务提供者GreetingsServiceImpl
中实现了这个接口。服务提供者配置了Dubbo的应用名、注册中心地址和服务协议及端口。服务消费者则通过Dubbo的ReferenceConfig获取远程服务的代理对象,并调用服务。
注意:实际使用时,需要配置正确的Zookeeper地址,并确保Zookeeper服务正常运行。同时,服务提供者需要先启动,并将服务注册到注册中心,服务消费者才能发现并调用服务。