Dubbo入门示例原生API版_原生api实现dubbo调用-程序员宅基地

技术标签: zookeeper  原生api  dubbo  Dubbo  bootstrap  

有关dubbo的基础、架构等介绍请参考之前博客:Dubbo背景及架构简介
XML版(官方推荐)示例请参考:

1. 创建暴露服务模块(dubbo-demo-api)

本模块下没有实际的业务逻辑,主要是定义提供者和消费者公用服务接口

/**
 * 需要暴露出去的服务
 *
 */
public interface HelloService {
    
	/**
	 * say hello
	 * 
	 * @param name
	 * @return
	 */
	String sayHello(String name);

}

2. 创建服务提供者和消费者父模块管理和引入公用依赖

依赖版本管理在父工程(dubbo-demo),采用dubbo-2.7.5
和xml或者注解版本不同的是不需要依赖spring

<?xml version="1.0"?>
<project
	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"
	xmlns="http://maven.apache.org/POM/4.0.0"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
	<modelVersion>4.0.0</modelVersion>
	<parent>
		<groupId>com.qqxhb</groupId>
		<artifactId>dubbo-demo</artifactId>
		<version>0.0.1</version>
	</parent>
	<artifactId>dubbo-api-demo</artifactId>
	<packaging>pom</packaging>
	<name>dubbo-api-demo</name>

	<dependencies>
		<!-- 引入Dubbo依赖,原生api不需要依赖spring -->
		<dependency>
			<groupId>org.apache.dubbo</groupId>
			<artifactId>dubbo</artifactId>
			<exclusions>
				<exclusion>
					<groupId>org.springframework</groupId>
					<artifactId>spring-context</artifactId>
				</exclusion>
			</exclusions>
		</dependency>
		<!-- 使用zookeeper作为注册中心 -->
		<dependency>
			<groupId>org.apache.zookeeper</groupId>
			<artifactId>zookeeper</artifactId>
		</dependency>
		<!-- 使用curator作为zookeeper客户端 -->
		<dependency>
			<groupId>org.apache.curator</groupId>
			<artifactId>curator-recipes</artifactId>
		</dependency>
		<!-- 引入需要暴露的服务 -->
		<dependency>
			<groupId>com.qqxhb</groupId>
			<artifactId>dubbo-demo-api</artifactId>
			<version>0.0.1</version>
		</dependency>
	</dependencies>
	<modules>
		<module>dubbo-api-demo-consumer</module>
		<module>dubbo-api-demo-provider</module>
	</modules>
</project>
3. 创建服务提供者

1).创建dubbo-api-demo-provider模块
2).编写服务实现类和启动类(两种启动方式)

1).创建dubbo-api-demo-provider模块

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
		<groupId>com.qqxhb</groupId>
        <artifactId>dubbo-api-demo</artifactId>
        <version>0.0.1</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>dubbo-api-demo-provider</artifactId>

</project>

2).编写服务实现类(HelloServiceImpl)和启动类(BootstrapProviderApplication及ExportProviderApplication)

package com.qqxhb.api.provider.impl;

import org.apache.dubbo.rpc.RpcContext;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.qqxhb.demo.api.HelloService;

public class HelloServiceImpl implements HelloService {
    
	private static final Logger logger = LoggerFactory.getLogger(HelloServiceImpl.class);

	public String sayHello(String name) {
    
		logger.info("========Hello " + name + ", request from consumer: " + RpcContext.getContext().getRemoteAddress());
		return "Hello " + name + ", response from provider: " + RpcContext.getContext().getLocalAddress();
	}
}

package com.qqxhb.api.provider;

import org.apache.dubbo.config.ApplicationConfig;
import org.apache.dubbo.config.RegistryConfig;
import org.apache.dubbo.config.ServiceConfig;
import org.apache.dubbo.config.bootstrap.DubboBootstrap;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.qqxhb.api.provider.impl.HelloServiceImpl;
import com.qqxhb.demo.api.HelloService;

/**
 * 
 * 通过DubboBootstrap方式启动服务
 *
 */
public class BootstrapProviderApplication {
    
	private static final Logger logger = LoggerFactory.getLogger(ExportProviderApplication.class);

	public static void main(String[] args) throws Exception {
    
		ServiceConfig<HelloServiceImpl> service = new ServiceConfig<>();
		service.setInterface(HelloService.class);
		service.setRef(new HelloServiceImpl());

		DubboBootstrap bootstrap = DubboBootstrap.getInstance();
		bootstrap.application(new ApplicationConfig("dubbo-api-demo-provider"))
				.registry(new RegistryConfig("zookeeper://127.0.0.1:2181")).service(service).start();
		logger.info("dubbo service started......");
		bootstrap.await();
	}
}

package com.qqxhb.api.provider;

import java.util.concurrent.CountDownLatch;

import org.apache.dubbo.config.ApplicationConfig;
import org.apache.dubbo.config.RegistryConfig;
import org.apache.dubbo.config.ServiceConfig;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.qqxhb.api.provider.impl.HelloServiceImpl;
import com.qqxhb.demo.api.HelloService;

/**
 * 
 * 通过服务导出的方式启动服务
 *
 */
public class ExportProviderApplication {
    
	private static final Logger logger = LoggerFactory.getLogger(ExportProviderApplication.class);

	public static void main(String[] args) throws Exception {
    
		ServiceConfig<HelloServiceImpl> service = new ServiceConfig<>();
		service.setInterface(HelloService.class);
		service.setRef(new HelloServiceImpl());

		service.setApplication(new ApplicationConfig("dubbo-api-demo-provider"));
		service.setRegistry(new RegistryConfig("zookeeper://127.0.0.1:2181"));
		service.export();
		logger.info("dubbo service started......");
		new CountDownLatch(1).await();
	}
}

4. 创建服务消费者

1).创建dubbo-api-demo-consumer模块
2).消费者启动类(同样有两种方式)

1).创建dubbo-api-demo-consumer模块

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
		<groupId>com.qqxhb</groupId>
        <artifactId>dubbo-api-demo</artifactId>
        <version>0.0.1</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>dubbo-api-demo-consumer</artifactId>
</project>

2).消费者启动类(BootstrapConsumerApplication 、ExportConsumerApplication)

package com.qqxhb.api.consumer;

import org.apache.dubbo.config.ApplicationConfig;
import org.apache.dubbo.config.ReferenceConfig;
import org.apache.dubbo.config.RegistryConfig;
import org.apache.dubbo.config.bootstrap.DubboBootstrap;
import org.apache.dubbo.config.utils.ReferenceConfigCache;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.qqxhb.demo.api.HelloService;

/**
 * 
 * 通过DubboBootstrap方式启动服务
 *
 */
public class BootstrapConsumerApplication {
    
	private static final Logger logger = LoggerFactory.getLogger(BootstrapConsumerApplication.class);

	public static void main(String[] args) throws Exception {
    
		ReferenceConfig<HelloService> reference = new ReferenceConfig<>();
		reference.setInterface(HelloService.class);

		DubboBootstrap bootstrap = DubboBootstrap.getInstance();
		bootstrap.application(new ApplicationConfig("dubbo-api-demo-consumer"))
				.registry(new RegistryConfig("zookeeper://127.0.0.1:2181")).reference(reference).start();
		HelloService helloService = ReferenceConfigCache.getCache().get(reference);
		String message = helloService.sayHello("Dubbo Bootstrap");
		logger.info("============{}", message);

	}
}

package com.qqxhb.api.consumer;

import org.apache.dubbo.config.ApplicationConfig;
import org.apache.dubbo.config.ReferenceConfig;
import org.apache.dubbo.config.RegistryConfig;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.qqxhb.demo.api.HelloService;

/**
 * 
 * 通过服务导出的方式调用服务
 *
 */
public class ExportConsumerApplication {
    
	private static final Logger logger = LoggerFactory.getLogger(BootstrapConsumerApplication.class);

	public static void main(String[] args) throws Exception {
    
		ReferenceConfig<HelloService> reference = new ReferenceConfig<>();
		reference.setApplication(new ApplicationConfig("dubbo-demo-api-consumer"));
		reference.setRegistry(new RegistryConfig("zookeeper://127.0.0.1:2181"));
		reference.setInterface(HelloService.class);
		HelloService service = reference.get();
		String message = service.sayHello("Dubbo Export");
		logger.info("============{}", message);
	}
}

5. 启动测试

1).依赖zookeeper作为注册中心,因此需要优先启动zookeeper
zookeeper相关知识请参考之前博客:Zookeeper入门及单机及集群环境搭建
2). 启动任意一个 ProviderApplication 、启动任意一个ConsumerApplication
ProviderApplication 端窗口打印日志======== result: Hello Dubbo Bootstrap, response from provider: 192.168.25.1:20880
ConsumerApplication 端窗口打印日志========Hello Dubbo Bootstrap, request from consumer: /192.168.25.1:7079

源码地址:https://github.com/qqxhb/dubbo-demo

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/qq_43792385/article/details/105240075

智能推荐

基于python的信用卡评分模型_python 信用 评分卡模型-程序员宅基地

文章浏览阅读4.4w次,点赞45次,收藏418次。基于python的信用卡评分模型1. 项目背景介绍1.1 信用风险和评分卡模型的基本概念 信用风险指的是交易对手未能履行约定合同中的义务造成经济损失的风险,即受信人不能履行还本付息的责任而使授信人的预期收益与实际收益发生偏离的可能性,它是金融风险的主要类型。 借贷场景中的评分卡是一种以分数的形式来衡量风险几率的一种手段,也是对未来一段时间内违约、逾期、失联概率的预测。一般来说..._python 信用 评分卡模型

linux 下 tcpdump 详解 前篇(libpcap库源码分析)_libcap 源码-程序员宅基地

文章浏览阅读1.7k次,点赞3次,收藏22次。一 概述用简单的话来定义tcpdump,就是:dump the traffic on a network,根据使用者的定义对网络上的数据包进行截获的包分析工具。 至于tcpdump参数如何使用,这不是本章讨论的重点。liunx系统抓包工具,毫无疑问就是tcpdump。而windows的抓包工具,wireshark也是一款主流的抓包工具。wireshark 使用了winpcap库。tcpdump..._libcap 源码

http://mirrors.aliyun.com/epel/6/x86_64/repodata/repomd.xml: [Errno 14] PYCURL ERROR 22 --程序员宅基地

文章浏览阅读6.5k次,点赞14次,收藏11次。http://mirrors.aliyun.com/epel/6/x86_64/repodata/repomd.xml: [Errno 14] PYCURL ERROR 22 - “The requested URL returned error: 404 Not Found”Trying other mirror.Error: Cannot retrieve repository metadata (repomd.xml) for repository: epel. Please verify its_/epel/6/x86_64/repodata/repomd.xml: [errno 14] pycurl error 22 - "the reques

Audio System 九 之 AudioTrack_audiotrackserverproxy-程序员宅基地

文章浏览阅读1k次。Audio System 九 之 AudioTrack十四、AudioTrack & AudioFlinger 相关类14.1 AudioTrack & AudioFlinger 的类图14.1.1 AudioFlinger::PlaybackThread 回放线程基类14.1.2 AudioFlinger::PlaybackThread::Track 音频流管理类14.1...._audiotrackserverproxy

Redis 通用命令(keys,help,mset,exists,expire,ttl,tab补全)_redis如何添加help命令-程序员宅基地

文章浏览阅读874次。redis 通用命令 _redis如何添加help命令

google chromeDriver 地址

chrome driver 下载地址。#chrome brower下载地址。#安装openssl 1.1.1K。#安装chrome driver。#安装browser。

随便推点

实现RTSP摄像机进行网页直播和微信直播的技术方案:EasyNVR版本免费更新方法_easynvr免费版-程序员宅基地

文章浏览阅读2.7k次。问题背景前文我们提过为保障服务器正常稳定运作,EasyNVR有专业的运维(售前支撑、商务咨询、售后维护)团队,随时对客户各种突发情况快速响应处理,保证互联网直播的顺利进行。这部分工作就包括技术问题咨询、需求分析、方案制定、版本更新、功能提升等,随着用户基数的增加,运维过程中或多或少存在一些回复延迟,主要包括以下几个方面:EasyNVR的用户越来越多,技术人员一一对应解答效率不高;随着Eas..._easynvr免费版

P1541 [NOIP2010 提高组] 乌龟棋 题解_乌龟棋2010-程序员宅基地

文章浏览阅读401次,点赞3次,收藏4次。更好的阅读体验蒟蒻的第一篇题解P1541 [NOIP2010 提高组] 乌龟棋简单的背包 首先确定状态,dp[a][b][c][d]用来存储使用a张爬行卡片1,b张爬行卡片2,c张爬行卡片3,d张爬行卡片4时的最大得分。 我们需要开一个桶的数组t存4种牌的个数,以便于暴力。 dp数组初始化。很显然,四种卡片都用0张时,在起点,分数为score[1] 即: dp[0][0][0][0]=score[1]; 状态转移。DP 4种卡片的个数,状态转移方程为_乌龟棋2010

计算机网络 | 划分子网_计算机网络子网划分-程序员宅基地

文章浏览阅读5.5k次,点赞11次,收藏69次。划分子网概念先知了解 什么是子网?了解 为什么要划分子网?划分子网的好处/优点是什么?介绍 子网掩码总结 子网掩码记住 IP 地址的自然分类问题求解一个网络,主机号有x位,则这个网络可以分配给主机的IP地址有多少个?子网划分实例问题1题目分析题目解题方法参考内容概念先知了解 什么是子网?子网或子网络是网络内部的网络。子网使网络更高效。通过子网划分,网络流量传播距离更短,无需通过不必要的路由器即可到达目的地。了解 为什么要划分子网?划分子网的好处/优点是什么?1.减少广播带来的负面影响2.节_计算机网络子网划分

Java利用JNA调用C#的dll-程序员宅基地

文章浏览阅读7.3k次,点赞2次,收藏23次。https://www.cnblogs.com/wyongbo/p/jnaTest.html本文参考以上链接,结合自己实际遇到的问题,做过一些修改(红色字体标注),主要是为了给自己做个笔记。一、需求阐述:  如果我们的项目利用c#开发,到了开发后期需要和java组进行合作,其中有一部分业务逻辑利用c#已经code completed,那么我们可能会考虑用java来调用现成的c#dll实...

linux查看系统编码和修改系统编码的方法_linux 机器编码设置-程序员宅基地

文章浏览阅读1.4w次。查看支持的字符编码使用locale命令,如:. 代码如下:# localeLANG=en_US.UTF-8LC_CTYPE="en_US.UTF-8"LC_NUMERIC="en_US.UTF-8"LC_TIME="en_US.UTF-8"LC_COLLATE="en_US.UTF-8"LC_MONETARY="en_US.UTF-8"LC_MESSAG_linux 机器编码设置

企业微信小程序_小程序开发工具及真机调试_host配置及代理_微信开发者工具 本地代理-程序员宅基地

文章浏览阅读7.6k次。文章目录一、开发前准备1. 开发文档2. 工具安装3. 安装插件4. 调整编译模式5. 选择企业6. PC 调试前端7. PC 调试后端二、甄姬调试前端2.1. 预览小程序2.2. 手机企微扫码2.3. 手机企微调试2.4. 多场景调试2.5. 手机企微调试前后端一、开发前准备1. 开发文档小程序开发文档:https://developer.work.weixin.qq.com/document/path/91502点击企业微信小程序开发进入详情页面2. 工具安装微信开发者工具3. ._微信开发者工具 本地代理