zookeeper+dubbo+dubbo 的管理界面的入门案例

dubbo

佬油条

12046人浏览 · 2016-06-22 18:02:12

佬油条 · 2016-06-22 18:02:12 发布

首先下载zookeepr-3.4.8,据说是一个比较稳定的版本，所有我选它了

下载地址 http://www.apache.org/dist/zookeeper/

下载好之后创建几个目录，然后每个目录里面解压一份，我没那么多机器只能做成伪分布式。

然后在每个目录里面创建一个data文件夹，里面创建一个文件myid写着每个文件对应的server ID.

比如我创建了三个目录，分别是server1、server2、server3，三个目录下都创建了data文件夹，data文件夹里面创建了myid文件，

各自对应的写了 id在里面，也就是server1里面的data 的myid 写的是1 ，server2写的2。

然后修改zookeepr 的启动配置，将解压出来的zookeepr里面的conf/zoo_sample.cfg 复制一份，重命名为zoo.cfg

然后修改

dataDir=D:/tool/server1/data --data目录的配置，我的是window系统弄的所有有D盘

clientPort=2181 --端口每个server 都要不一样

server.1=127.0.0.1:8881:7771
server.2=127.0.0.1:8882:7772
server.3=127.0.0.1:8883:7773

最后几行唯一需要注意的地方就是 server.X 这个数字就是对应 data/myid中的数字。你在3个server的myid文件中分别写入了1，2，3，那么每个server中的zoo.cfg都配 server.1,server.2,server.3就OK了。因为在同一台机器上，后面连着的2个端口3个server都不要一样，否则端口冲突，其中第一个端口用来集群成员的信息交换，第二个端口是在leader挂掉时专门用来进行选举leader所用。
进入zookeeper-3.3.2/bin 目录中，./zkServer.sh start启动一个server,这时会报大量错误？其实没什么关系，因为现在集群只起了1台server，zookeeper服务器端起来会根据 zoo.cfg的服务器列表发起选举leader的请求，因为连不上其他机器而报错，那么当我们起第二个zookeeper实例后，leader将会被选出，从而一致性服务开始可以使用，这是因为3台机器只要有2台可用就可以选出leader并且对外提供服务(2n+1台机器，可以容n台机器挂掉)。

每个zookeepr 都要对应的配置，然后点击zkServer.cmd 启动，前面启动的都会报错，不用理会。

随便找其中的一个server1/bin/zkCli.cmd 文件启动，测试下是否启动成功，

那么，首先我们随便打个命令，因为zookeeper不认识，他会给出命令的help,如下图

ls(查看当前节点数据),
ls2(查看当前节点数据并能看到更新次数等数据) ,
create(创建一个节点) ,
get(得到一个节点，包含数据和更新次数等数据),
set(修改节点)
delete(删除一个节点)

这个时候证明zookeepr 的服务已经正常启动了，然后开始新建一个web项目，我是用的maven创建的，spring用的4.1.5的版本.

另外必须的两个包有duboo和zookeepr的client包，还有些log包就自己看着加。

<!-- dubbo -->
		<dependency>
			<groupId>com.alibaba</groupId>
			<artifactId>dubbo</artifactId>
			<version>2.5.3</version>
			<exclusions>
				<exclusion>
					<groupId>org.springframework</groupId>
					<artifactId>spring</artifactId>
				</exclusion>
			</exclusions>
		</dependency> 
		<!-- zookeepr -->
		<dependency>
		    <groupId>com.101tec</groupId>
		    <artifactId>zkclient</artifactId>
		    <version>0.4</version>
		</dependency>

创建一个接口，一个实体类，一个接口实现类。

package com.dashu.dubbo.provider;

import java.util.List;

public interface DemoServer {

	public String sayHello(String name);
	
	public List getUsers();  
}

package com.dashu.dubbo.entity;

import java.io.Serializable;

public class User implements Serializable{
	private static final long serialVersionUID = -8295790380194607068L;
	private String name;
	private String sex;
	private Integer age;
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	public String getSex() {
		return sex;
	}
	public void setSex(String sex) {
		this.sex = sex;
	}
	public Integer getAge() {
		return age;
	}
	public void setAge(Integer age) {
		this.age = age;
	}
	
	
}

package com.dashu.dubbo.provider.impl;

import java.util.ArrayList;
import java.util.List;

import com.dashu.dubbo.entity.User;
import com.dashu.dubbo.provider.DemoServer;

public class DemoServiceImpl implements DemoServer{

	@Override
	public String sayHello(String name) {
		return "hello,"+name;
	}

	@Override
	public List getUsers() {
		   List list = new ArrayList();  
	         User u1 = new User();  
	         u1.setName("jack");  
	         u1.setAge(20);  
	         u1.setSex("男");  
	           
	         User u2 = new User();  
	         u2.setName("tom");  
	         u2.setAge(21);  
	         u2.setSex("女");  
	           
	         User u3 = new User();  
	         u3.setName("rose");  
	         u3.setAge(19);  
	         u3.setSex("女");  
	           
	         list.add(u1);  
	         list.add(u2);  
	         list.add(u3);  
	         return list;  
	}

}

然后配置spring.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context" xsi:schemaLocation="
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-3.0.xsd
http://code.alibabatech.com/schema/dubbo  
http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

	    <!-- 具体的实现bean -->  
    <bean id="demoService" class="com.dashu.dubbo.provider.impl.DemoServiceImpl" />  
      
    <!-- 提供方应用信息，用于计算依赖关系 -->  
    <dubbo:application name="andy_provider"  />  
   
    <!-- 使用multicast广播注册中心暴露服务地址   
    <dubbo:registry address="multicast://224.5.6.7:1234" />-->  
    
    <!-- 使用zookeeper注册中心暴露服务地址 -->  
    <dubbo:registry address="zookeeper://127.0.0.1:2181" />   
    
    <!-- 用dubbo协议在20880端口暴露服务 -->  
    <dubbo:protocol name="dubbo" port="20880" />  
   
    <!-- 声明需要暴露的服务接口 -->  
    <dubbo:service interface="com.dashu.dubbo.provider.DemoServer" ref="demoService" />

然后将项目运行起来就完成了服务的提供，然后实现服务的使用方法。

新建一个项目，将之前的包都拷贝过来，然后写个和提供服务一样的接口，另外把实体类也拷贝过来，实体类是要实现序列化的。

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context" xsi:schemaLocation="
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-3.0.xsd
http://code.alibabatech.com/schema/dubbo  
http://code.alibabatech.com/schema/dubbo/dubbo.xsd">


	<!-- 自动扫描(自动注入) --> 
	<context:component-scan base-package="com.dashu.dubooClient" />
 <!-- consumer application name -->
 <dubbo:application name="consumer-of-helloworld-app" />
 <!-- registry address, used for consumer to discover services -->
 <dubbo:registry address="zookeeper://127.0.0.1:2181" />
 <dubbo:consumer timeout="5000" />
 <!-- which service to consume? -->
 <dubbo:reference id="demoService"  interface="com.dashu.dubbo.provider.DemoServer" />
	
</beans>

然后写个测试的main方法。

public class Test {
	public static void main(String[] args) throws Exception {
	     
	     ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] {"spring.xml"});
	        context.start();
	        DemoServer demoService = (DemoServer) context.getBean("demoService"); // get
	        // service
	        // invocation
	        // proxy
	        String hello = "";
	        try {
	         hello = demoService.sayHello("dubbo");
	         System.out.println(hello);
	         List<User> list = demoService.getUsers();
	         System.out.println("一共有"+list.size()+"个用户!");
	        } catch (Exception e) {
	         // TODO Auto-generated catch block
	         e.printStackTrace();
	        } // do invoke!
	        System.out.println(Thread.currentThread().getName() + " " + hello);
	    }
}

如图显示就算是完成了基本的调用。

最后还有一个服务的管理平台可以查看自己的dubbo服务，查看使用状态什么的。

需要下载dubbo-admin-2.4.1.war 包，下载地址http://download.csdn.net/detail/wangzhi291/9558577

新找一个Tomcat tomcat/webapps/ROOT/目录下的东西必须删除干净，然后将war包解压到这个目录下来，

是ROOT目录下，然后配置解压后的dubbo.properties 文件，直接修改就可以；

文件地址为 webapps/ROOT/WEB-INF/dubbo.properties

 
  dubbo.registry.address=zookeeper://127.0.0.1:2181 
 
  dubbo.admin.root.password=root 
 
  dubbo.admin.guest.password=guest

将红色的修改为你的地址和端口就行。然后启动tomcat

在浏览器上输入自己的IP和端口就行，然后提示用户名和密码 root/root就行

成功后如图：

其中就有你之前提供的服务，注意dubbo-admin-2.4.1.war 单独找个tomcat 别和之前的服务提供方一起。

感觉可以了就赶紧试试吧。

向您推荐>>Eolink开发者社区

权威｜前沿｜技术｜干货｜国内首个API全生命周期开发者社区

更多推荐

深入理解 Mocha 测试框架：从零实现一个 Mocha

前言什么是自动化测试自动化测试在很多团队中都是Devops环节中很难执行起来的一个环节，主要原因在于测试代码的编写工作很难抽象，99%的场景都需要和业务强绑定，而且写测试代码的编写工作量往往比编写实际业务代码的工作量更多。在一些很多业务场景中投入产出比很低，适合写自动化测试的应该是那些中长期业务以及一些诸如组件一样的基础库。自动化测试是个比较大的概念，其中分类也比较多，比如单元测试，端对端测试，集

云原生

ELK实现containerd的容器日志采集展示【基于logging的全栈监测】

企业级ELK Stack构建介绍

云原生

(20200916 Solved)docker-compose up创建容器自动退出

问题描述如题，创建容器后自动退出了。并且docker start container无效解决方案原因是缺失了控制终端的配置，需要在docker-compose.yml中增加tty:true ，有时候这样也不行，需要再增加一个command:/bin/bash，命令不一定是这个，需要是一个不会退出的命令，然后用-d后台启动容器。Referencesdocker-compose启动容器后自动退出...

云原生

所有评论(0)

查看更多评论

佬油条

@wangzhi291

已为社区贡献1条内容