dubbo+zookeeper+dubboadmin环境搭建
2024-10-21 19:08:37
4、环境搭建
4.1、zookeeper注册中心的配置安装(在windows平台下,Linux类似,见官方文档)(Redis注册中心安装,简易注册中心安装,简易监控中心安装,见官方文档)
-
# The number of milliseconds of each tick//ZK中的一个时间单元2000ms
tickTime=2000
# The number of ticks that the initial
# synchronization phase can take//Leader允许Follower在initLimit时间内完成初始化工作。
initLimit=10
# The number of ticks that can pass between
# sending a request and getting an acknowledgement
syncLimit=5
# the directory where the snapshot is stored.\\就是把内存中的数据存储成快照文件snapshot的目录
dataDir=E:\\dubbo\\zookeeperB\\data
# the port at which the clients will connect
clientPort=2181
-
- 然后就可以启动zk了点击\bin\路径下面的zkServer.cmd
运行:
4.2、监控中心的安装配置
- 首先下载tomacat,安装配置(略)
- 下载dubbo-admin包(dubbo-admin-2.5.4-SNAPSHOT.war)
- 找到 tomcat安装路径下的 .\webapps\ROOT目录,然后清空里面的所有文件
- 将dubbo-admin包(dubbo-admin-2.5.4-SNAPSHOT.war)解压到此文件中
- 在解压的文件中找到\WEB-INF文件夹下的dubbo.properties文件,然后进行配置,默认属性配置如下:
dubbo.registry.address=zookeeper://127.0.0.1:2181
dubbo.admin.root.password=root
dubbo.admin.guest.password=guest
- 然后启动tomcat(zookeeper已启动,此步tomcat要访问zookeeper,如果zk没有启动,tomcat会一直等待其启动)。在浏览器中输入localhost:8080,进入监控中心的管理界面(默认管理员账户密码为:root,root)
4.3、服务提供者和消费者:
- 服务提供者和服务消费者简单的示例:下面是eclipse平台下的服务提供者和服务消费者java项目截图
- service的代码:(consumer和provider中的Service接口一样,其包名也要保持一致)
-
package com.renhq.dubbotest.provider;
publicinterfaceService{
String sayHello(String name);
}
-
- ServiceIm的代码:
-
package com.renhq.dubbotest.providerIm;
import java.io.IOException;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.renhq.dubbotest.provider.Service;
publicclassServiceImimplementsService{
publicString sayHello(String name){
return"Hello "+ name;
}
publicstaticvoid main(String[] args)throwsIOException{
ClassPathXmlApplicationContext context =newClassPathXmlApplicationContext("provider.xml");
context.start();
System.in.read();
}
}
-
- provider.xml的配置:
-
<?xml version="1.0" encoding="UTF-8"?>
<beansxmlns="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:applicationname="hello-world-provider"/>
<!-- 使用multicast广播注册中心暴露服务地址
<dubbo:registry address="multicast://224.5.6.7:1234" /> -->
<!-- 用dubbo协议在20880端口暴露服务 -->
<dubbo:protocolname="dubbo"port="20888"/>
<!-- 使用zookeeper注册中心暴露服务地址 -->
<dubbo:registryaddress="zookeeper://127.0.0.1:2181"/>
<!-- 声明需要暴露的服务接口 -->
<dubbo:serviceinterface="com.renhq.dubbotest.provider.Service"ref="demoService"/>
<!-- 和本地bean一样实现服务 -->
<beanid="demoService"class="com.renhq.dubbotest.providerIm.ServiceIm"/>
</beans>
-
- Consumer的代码:
-
package com.renhq.dubbotest.comsumer;
import java.io.IOException;
import java.util.Collections;
import java.util.HashMap;
import java.util.Map;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.renhq.dubbotest.provider.Service;
publicclassConsumer{
publicstaticvoid main(String[] args)throwsIOException{
ClassPathXmlApplicationContext context =newClassPathXmlApplicationContext("consumer.xml");
context.start();
// System.out.println("----------------nihao ----------------------"); // 显示调用结果
Service demoService =(Service) context.getBean("demoService");// 获取远程服务代理
String hello = demoService.sayHello("world");// 执行远程方法
System.out.println(hello);// 显示调用结果
System.in.read();
}
}
-
- consumer.xml的配置:
-
<?xml version="1.0" encoding="UTF-8"?>
<beansxmlns="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:applicationname="consumer-of-helloworld-app"/>
<!-- 使用multicast广播注册中心暴露发现服务地址 -->
<!-- <dubbo:registry address="multicast://224.5.6.7:1234" /> -->
<!-- 使用zookeeper注册中心暴露服务地址 -->
<dubbo:registryaddress="zookeeper://127.0.0.1:2181"/>
<!-- 生成远程服务代理,可以和本地bean一样使用demoService -->
<dubbo:referenceid="demoService"interface="com.renhq.dubbotest.provider.Service"/>
</beans>
-
- 没有注册中心情况下服务提供者和服务消费者的链接:
provider.xml的配置:
<!--在没有注册中心,直接暴露提供者的情况下,即:-->
<dubbo:serviceinterface="com.renhq.dubbotest.provider.Service"ref="demoService"registry="N/A"/>
consumer.xml的配置:
<!--直连引用服务:在没有注册中心,直连提供者的情况下-->
<dubbo:referenceid="demoService"interface="com.renhq.dubbotest.provider.Service"url="dubbo://192.168.1.103:20880/com.renhq.dubbotest.provider.Service"/>
- 运行结果(先运行provider项目进行服务注册,再运行consumer项目访问服务):provider:
- consumer
附件列表
最新文章
- 为什么C#中ref和out 关键字 ?
- Windows10 如何删掉内置的 skype ?
- 机器人操作系统(ROS)教程4:ROS的框架【转】
- Canu Quick Start(快速使用Canu)
- php 滑动验证码
- 如何动态添加和删除一个div
- vs2012 aspx 没有设计视图了?
- SCIP读书笔记(1)
- cocos2d-x创建工程批处理
- leetcode第40题--First Missing Positive
- Socket编程实践(13) --UNIX域协议
- VUE v-for问题
- Java 开源博客 Solo 1.9.0 发布 - 新皮肤
- tensorflow, TypeError:&#39;Tensor&#39; object is not callable
- Mysql innodb_fast_shutdown
- 宝塔使用FTP的问题
- 还有看不懂的java语句?
- what&#39;s the python之异常处理
- spfa 单源最短路究极算法
- 上机题目(0基础)- Java网络操作-打印网页(Java)
热门文章
- 解决没有referenced Libraries的方法
- 使用Intellij Idea打开项目不能显示树形目录
- 使用ES6的Promise 解决回调函数。
- 33 python 并发编程之IO模型
- 统计日志中ip出现的次数
- php 中改变字符编码的函数 是 iconv()
- LeetCode Second Minimum Node In a Binary Tree
- [转]HTTP详解(1)-工作原理
- [转]Angular移除不必要的$watch之性能优化
- Ubuntu下部署GitLab-——基于14.04系统