Dubbo+zookeeper构建高可用分布式集群(二)

Stella981
• 阅读 724

Dubbo+zookeeper构建高可用分布式集群(一)-单机部署中我们讲了如何单机部署。但没有将如何配置微服务。下面分别介绍单机与集群微服务如何配置注册中心。

Zookeeper单机配置:
方式一、

<dubbo:registry
address="zookeeper://10.20.153.10:2181"/>

方式二、

<dubbo:registry
protocol="zookeeper"
address="10.20.153.10:2181"/> 

Zookeeper集群配置:

方式一、

<dubbo:registry address="zookeeper://10.20.153.10:2181?backup=10.20.153.11:2181,10.20.153.12:2181"/> 

方式二、

<dubbo:registry 
protocol="zookeeper"
address="10.20.153.10:2181,10.20.153.11:2181,10.20.153.12/>

集群配置方式一,特别适用于dubbo-admin 和dubbo-monitor

Zookeeper是什么:

Zookeeper,一种分布式应用的协作服务,是Google的Chubby一个开源的实现,是Hadoop的分布式协调服务,它包含一个简单的原语集,应用于分布式应用的协作服务,使得分布式应用可以基于这些接口实现诸如同步、配置维护和分集群或者命名的服务。

zookeeper是一个由多个service组成的集群,一个leader,多个follower,每个server保存一份数据部分,全局数据一致,分布式读写,更新请求转发由leader实施.

更新请求顺序进行,来自同一个client的更新请求按其发送顺序依次执行,数据更新原子性,一次数据更新要么成功,要么失败,全局唯一数据试图,client无论连接到哪个server,数据试图是一致的.

为什么要用zookeeper

大部分分布式应用需要一个主控、协调器或控制器来管理物理分布的子进程(如资源、任务分配等),目前,大部分应用需要开发私有的协调程序,缺乏一个通用的机制.协调程序的反复编写浪费,且难以形成通用、伸缩性好的协调器,ZooKeeper:提供通用的分布式锁服务,用以协调分布式应用

zookeeper工作原理

zookeeper的核心是原子广播,这个机制保证了各个server之间的同步,实现这个机制的协议叫做Zab协议.Zab协议有两种模式,他们分别是恢复模式和广播模式.

  1.当服务启动或者在领导者崩溃后,Zab就进入了恢复模式,当领导着被选举出来,且大多数server都完成了和leader的状态同步后,恢复模式就结束了.状态同步保证了leader和server具有相同的系统状态.

  2.一旦leader已经和多数的follower进行了状态同步后,他就可以开始广播消息了,即进入广播状态.这时候当一个server加入zookeeper服务中,它会在恢复模式下启动,发下leader,并和leader进行状态同步,待到同步结束,它也参与广播消息.

说明:

    广播模式需要保证proposal被按顺序处理,因此zk采用了递增的事务id号(zxid)来保证.所有的提议(proposal)都在被提出的时候加上了zxid.实现中zxid是一个64为的数字,它高32位是epoch用来标识leader关系是否改变,每次一个leader被选出来,它都会有一个新的epoch.低32位是个递增计数.

    当leader崩溃或者leader失去大多数的follower,这时候zk进入恢复模式,恢复模式需要重新选举出一个新的leader,让所有的server都恢复到一个正确的状态.

    zookeeper服务一致维持在Broadcast状态,直到leader崩溃了或者leader失去了大部分的followers支持.

    Broadcast模式极其类似于分布式事务中的2pc(two-phrase commit两阶段提交):即leader提起一个决议,由followers进行投票,leader对投票结果进行计算决定是否通过该决议,如果通过执行该决议(事务),否则什么也不做.

Leader选举

每个Server启动以后都询问其它的Server它要投票给谁,对于其他server的询问,server每次根据自己的状态都回复自己推荐的leader的id和上一次处理事务的zxid(系统启动时每个server都会推荐自己),收到所有Server回复以后,就计算出zxid最大的哪个Server,并将这个Server相关信息设置成下一次要投票的Server.计算这过程中获得票数最多的的sever为获胜者,如果获胜者的票数超过半数,则改server被选为leader.否则,继续这个过程,直到leader被选举出来.leader就会开始等待server连接,Follower连接leader,将最大的zxid发送给leader,Leader根据follower的zxid确定同步点,完成同步后通知follower已经成为uptodate状态,Follower收到uptodate消息后,又可以重新接受client的请求进行服务了.

zookeeper的数据模型

层次化的目录结构,命名符合常规文件系统规范

每个节点在zookeeper中叫做znode,并且其有一个唯一的路径标识

节点Znode可以包含数据和子节点,但是EPHEMERAL类型的节点不能有子节点

Znode中的数据可以有多个版本,比如某一个路径下存有多个数据版本,那么查询这个路径下的数据就需要带上版本

客户端应用可以在节点上设置监视器,节点不支持部分读写,而是一次性完整读写

Zoopkeeper 提供了一套很好的分布式集群管理的机制,就是它这种基于层次型的目录树的数据结构,并对树中的节点进行有效管理,从而可以设计出多种多样的分布式的数据管理模型

Zookeeper的节点

Znode有两种类型,短暂的(ephemeral)和持久的(persistent)

Znode的类型在创建时确定并且之后不能再修改

短暂znode的客户端会话结束时,zookeeper会将该短暂znode删除,短暂znode不可以有子节点

持久znode不依赖于客户端会话,只有当客户端明确要删除该持久znode时才会被删除

Znode有四种形式的目录节点,PERSISTENT、PERSISTENT_SEQUENTIAL、EPHEMERAL、EPHEMERAL_SEQUENTIAL.

znode 可以被监控,包括这个目录节点中存储的数据的修改,子节点目录的变化等,一旦变化可以通知设置监控的客户端,这个功能是zookeeper对于应用最重要的特性,

通过这个特性可以实现的功能包括配置的集中管理,集群管理,分布式锁等等.

Zookeeper的角色

领导者(leader),负责进行投票的发起和决议,更新系统状态

学习者(learner),包括跟随者(follower)和观察者(observer).

follower用于接受客户端请求并想客户端返回结果,在选主过程中参与投票

Observer可以接受客户端连接,将写请求转发给leader,但observer不参加投票过程,只同步leader的状态,observer的目的是为了扩展系统,提高读取速度

客户端(client),请求发起方

Watcher

Watcher 在 ZooKeeper是一个核心功能,Watcher可以监控目录节点的数据变化以及子目录的变化,一旦这些状态发生变化,服务器就会通知所有设置在这个目录节点上的Watcher,从而每个客户端都很快知道它所关注的目录节点的状态发生变化,而做出相应的反应

可以设置观察的操作:exists,getChildren,getData

可以触发观察的操作:create,delete,setData

znode以某种方式发生变化时,“观察”(watch)机制可以让客户端得到通知.

可以针对ZooKeeper服务的“操作”来设置观察,该服务的其他 操作可以触发观察.

比如,客户端可以对某个客户端调用exists操作,同时在它上面设置一个观察,如果此时这个znode不存在,则exists返回false,如果一段时间之后,这个znode被其他客户端创建,则这个观察会被触发,之前的那个客户端就会得到通知.

Zookeeper集群搭建

Zookeeper 不仅可以单机提供服务,同时也支持多机组成集群来提供服务,实际上Zookeeper还支持另外一种伪集群的方式,也就是可以在一台物理机上运行多个Zookeeper实例.

Zookeeper通过复制来实现高可用性,只要集合体中半数以上的机器处于可用状态,它就能够保证服务继续。

集群容灾性:

 3台机器只要有2台可用就可以选出leader并且对外提供服务(2n+1台机器,可以容n台机器挂掉)。

Zookeeper伪分布式环境搭建:

1、去Zookeeper官网下载最新版本的Zookeeper.

[root@localhost zookeeper-cluster]# pwd

/export/search/zookeeper-cluster

[root@localhost zookeeper-cluster]# ls

zookeeper-3.4.6.tar.gz

[root@localhost zookeeper-cluster]#

[root@localhost zookeeper-cluster]# tar -zxvf zookeeper-3.4.6.tar.gz

#创建第一个集群节点

[root@localhost zookeeper-cluster]# mv zookeeper-3.4.6 zookeeper-3.4.6-node1

[root@localhost zookeeper-cluster]# cd zookeeper-3.4.6-node1

[root@localhost zookeeper-3.4.6-node1]# pwd

/export/search/zookeeper-cluster/zookeeper-3.4.6-node1

#创建数据存放路径

[root@localhost zookeeper-3.4.6-node1]# mkdir data

[root@localhost zookeeper-3.4.6-node1]# cd ../

#创建第二第三个集群节点

[root@localhost zookeeper-cluster]# cp zookeeper-3.4.6-node1 zookeeper-3.4.6-node2 -R

[root@localhost zookeeper-cluster]# cp zookeeper-3.4.6-node1 zookeeper-3.4.6-node3 -R

[root@localhost zookeeper-cluster]# ls

zookeeper-3.4.6-node1  zookeeper-3.4.6-node2  zookeeper-3.4.6-node3  zookeeper-3.4.6.tar.gz

[root@localhost zookeeper-cluster]# cd zookeeper-3.4.6-node1/conf/

[root@localhost conf]# ls

configuration.xsl  log4j.properties  zoo_sample.cfg

#创建zoo.cfg文件

[root@localhost conf]# cp zoo_sample.cfg zoo.cfg

2、配置zoo.cfg文件:

#zookeeper-3.4.6-node1的配置

tickTime=2000

initLimit=10

syncLimit=5

clientPort=2181

dataDir=/export/search/zookeeper-cluster/zookeeper-3.4.6-node1/data

server.1=localhost:2887:3887

server.2=localhost:2888:3888

server.3=localhost:2889:3889

#zookeeper-3.4.6-node2的配置

tickTime=2000

initLimit=10

syncLimit=5

clientPort=2182

dataDir=/export/search/zookeeper-cluster/zookeeper-3.4.6-node2/data

server.1=localhost:2887:3887

server.2=localhost:2888:3888

server.3=localhost:2889:3889

#zookeeper-3.4.6-node3的配置

tickTime=2000

initLimit=10

syncLimit=5

clientPort=2183

dataDir=/export/search/zookeeper-cluster/zookeeper-3.4.6-node3/data

server.1=localhost:2887:3887

server.2=localhost:2888:3888

server.3=localhost:2889:3889

参数说明:

tickTime=2000:

tickTime这个时间是作为Zookeeper服务器之间或客户端与服务器之间维持心跳的时间间隔,也就是每个tickTime时间就会发送一个心跳;

initLimit=10:

initLimit这个配置项是用来配置Zookeeper接受客户端(这里所说的客户端不是用户连接Zookeeper服务器的客户端,而是Zookeeper服务器集群中连接到Leader的Follower服务器)初始化连接时最长能忍受多少个心跳时间间隔数。

当已经超过10个心跳的时间(也就是tickTime)长度后Zookeeper 服务器还没有收到客户端的返回信息,那么表明这个客户端连接失败。总的时间长度就是10*2000=20 秒;

syncLimit=5:

syncLimit这个配置项标识Leader与Follower之间发送消息,请求和应答时间长度,最长不能超过多少个tickTime的时间长度,总的时间长度就是5*2000=10秒;

dataDir=/export/search/zookeeper-cluster/zookeeper-3.4.6-node1/data

dataDir顾名思义就是Zookeeper保存数据的目录,默认情况下Zookeeper将写数据的日志文件也保存在这个目录里;

clientPort=2181

clientPort这个端口就是客户端连接Zookeeper服务器的端口,Zookeeper会监听这个端口接受客户端的访问请求;

server.1=localhost:2887:3887

server.2=localhost:2888:3888

server.3=localhost:2889:3889

server.A=B:C:D:

A是一个数字,表示这个是第几号服务器,B是这个服务器的ip地址

C第一个端口用来集群成员的信息交换,表示的是这个服务器与集群中的Leader服务器交换信息的端口

D是在leader挂掉时专门用来进行选举leader所用

3、创建ServerID标识

除了修改zoo.cfg配置文件,集群模式下还要配置一个文件myid,这个文件在dataDir目录下,这个文件里面就有一个数据就是A的值,在上面配置文件中zoo.cfg中配置的dataDir路径中创建myid文件

[root@localhost zookeeper-cluster]# cat /export/search/zookeeper-cluster/zookeeper-3.4.6-node1/data/myid

1

[root@localhost zookeeper-cluster]# cat /export/search/zookeeper-cluster/zookeeper-3.4.6-node2/data/myid

2

[root@localhost zookeeper-cluster]# cat /export/search/zookeeper-cluster/zookeeper-3.4.6-node3/data/myid

3

4、启动zookeeper

[root@localhost zookeeper-cluster]# /export/search/zookeeper-cluster/zookeeper-3.4.6-node1/bin/zkServer.sh start

JMX enabled by default

Using config: /export/search/zookeeper-cluster/zookeeper-3.4.6-node1/bin/../conf/zoo.cfg

Starting zookeeper ... STARTED

[root@localhost zookeeper-cluster]# /export/search/zookeeper-cluster/zookeeper-3.4.6-node2/bin/zkServer.sh start

JMX enabled by default

Using config: /export/search/zookeeper-cluster/zookeeper-3.4.6-node2/bin/../conf/zoo.cfg

Starting zookeeper ... STARTED

[root@localhost zookeeper-cluster]# /export/search/zookeeper-cluster/zookeeper-3.4.6-node3/bin/zkServer.sh start

JMX enabled by default

Using config: /export/search/zookeeper-cluster/zookeeper-3.4.6-node3/bin/../conf/zoo.cfg

Starting zookeeper ... STARTED

5、检测集群是否启动

[root@localhost zookeeper-cluster]# echo stat|nc localhost 2181

[root@localhost zookeeper-cluster]# echo stat|nc localhost 2182

[root@localhost zookeeper-cluster]# echo stat|nc localhost 2183

#或者

[root@localhost zookeeper-cluster]# /export/search/zookeeper-cluster/zookeeper-3.4.6-node1/bin/zkCli.sh

[root@localhost zookeeper-cluster]# /export/search/zookeeper-cluster/zookeeper-3.4.6-node2/bin/zkCli.sh

[root@localhost zookeeper-cluster]# /export/search/zookeeper-cluster/zookeeper-3.4.6-node3/bin/zkCli.sh

伪集群部署注意事项:

在一台机器上部署了3个server;需要注意的是clientPort这个端口,如果在1台机器上部署多个server,那么每个server都要有不同的clientPort.

比如 server.1是2181,server.2是2182,server.3是2183

最后几行唯一需要注意的地方就是

server.X 这个数字就是对应 data/myid中的数字。你在3个server的myid文件中分别写入了1,2,3,那么每个server中的zoo.cfg都配server.1,server.2,server.3就OK了

集成dubbo时的配置:

提供者:

<dubbo:registry protocol="zookeeper"  address="192.168.8.101:2181,192.168.8.101:2182,192.168.8.101:2183" />

消费者:

<dubbo:registry protocol="zookeeper"   address="192.168.8.101:2181,192.168.8.101:2182,192.168.8.101:2183" />

具体详情可以参考:https://github.com/alibaba/dubbo

第二步:下载,配置dubbo的管理项目

2.1 下载 dubbo admin 项目 地址: http://dubbo.io/Download-zh.htm

2.2 解压,取出war包。

2.3 拷贝一个tomcat,改一下端口号(用默认容易和其他的tomcat端口冲突)

Dubbo+zookeeper构建高可用分布式集群(二)

2.4 删除 tomcat webapp 目录下面的文件,将dubbo admin 包解压内容放到root目录中,修改classpath 目录下的dubbo.properties, 将这个监测中心注册到zookeeper,即将dubbo.registry.address改成你安装zookeeper的机子IP+zookeeper配置的端口。我这里是一台机子演示,默认端口与zookeeper是一致的所以不用修改。用户名密码就没有改动的必要了。

Dubbo+zookeeper构建高可用分布式集群(二)

2.5 bin目录启动tomcat,输入这个tomat的访问网址 http://localhost:8180/ (端口号注意修改成你自己改的那个),然后登陆密码都是就是上面配置文件中的,root  root登录

Dubbo+zookeeper构建高可用分布式集群(二)

这里可以看到,提供者为0,消费者为0

第三步:创建提供者

3.1:创建公用接口项目 service,创建两个provider (provider01,provider02)

Dubbo+zookeeper构建高可用分布式集群(二)

service包,公用接口,很简单,就是个maven基础java包,不需要加入任何依赖,也不需要加入任何配置文件

[html] view plain copy

  1. <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"\>
  2.   <modelVersion>4.0.0</modelVersion>
  3.   <groupId>com.test</groupId>
  4.   <artifactId>service</artifactId>
  5.   <version>0.0.1-SNAPSHOT</version>
  6. </project>

2个provider包引入service依赖,且需要引入dubbo,zookeeper,log4依赖,这里不需要引入Spring,dubbo自带依赖,不过版本很旧,也可以自己手动移除然后引入新版本Spring。下面给出其中一个的pom实例,copy请自行修改artifactId

pom.xml:

[html] view plain copy

  1. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

  2.     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"\>

  3.     <modelVersion>4.0.0</modelVersion>

  4.     <groupId>com.test</groupId>

  5.     <artifactId>provider02</artifactId>

  6.     <version>0.0.1-SNAPSHOT</version>

  7.     <dependencies>

  8.         <dependency>

  9.             <groupId>com.test</groupId>

  10.             <artifactId>service</artifactId>

  11.             <version>0.0.1-SNAPSHOT</version>

  12.         </dependency>

  13.         <dependency>

  14.             <groupId>com.alibaba</groupId>

  15.             <artifactId>dubbo</artifactId>

  16.             <version>2.5.3</version>

  17.         </dependency>

  18.         <dependency>

  19.             <groupId>org.apache.zookeeper</groupId>

  20.             <artifactId>zookeeper</artifactId>

  21.             <version>3.3.3</version>

  22.         </dependency>

  23.         

  24.         <dependency>

  25.             <groupId>log4j</groupId>

  26.             <artifactId>log4j</artifactId>

  27.             <version>1.2.16</version>

  28.         </dependency>

  29.         <dependency>

  30.             <groupId>org.slf4j</groupId>

  31.             <artifactId>slf4j-api</artifactId>

  32.             <version>1.7.5</version>

  33.         </dependency>

  34.         

  35.         <dependency>

  36.             <groupId>com.github.sgroschupf</groupId>

  37.             <artifactId>zkclient</artifactId>

  38.             <version>0.1</version>

  39.         </dependency>

  40.     </dependencies>

  41.     <build>

  42.         <pluginManagement>

  43.             <plugins>

  44.                 <plugin>

  45.                     <groupId>org.apache.maven.plugins</groupId>

  46.                     <artifactId>maven-jar-plugin</artifactId>

  47.                     <configuration>

  48.                         <source>1.8</source>

  49.                         <target>1.8</target>

  50.                         <archive>

  51.                             <manifest>

  52.                                 <mainClass>com.test.provider.Provider</mainClass>

  53.                                 <addClasspath>true</addClasspath>

  54.                                 <classpathPrefix>lib/</classpathPrefix>

  55.                             </manifest>

  56.                         </archive>

  57.                         <classesDirectory>

  58.                         </classesDirectory>

  59.                     </configuration>

  60.                 </plugin>

  61.             </plugins>

  62.         </pluginManagement>

  63.     </build>

  64. </project>

3.2  在service公有服务接口包中新建接口TestService,内容很简单,就包含一个测试接口

TestService.java:

[java] view plain copy

  1. package com.test.service;

  2. /**

  3. * @author xianghui1

  4. *

  5. *test

  6. */

  7. public interface TestService {

  8.     public String test();

  9. }

  

3.3  provider 提供者需要实现这个公用接口以向消费者提供服务,两个provider基本是一样的,除了部分配置

provider02 :   TestServiceImpl.java实现公有接口 testService

[java] view plain copy

  1. package com.test.service;

  2. import com.test.service.TestService;

  3. public class TestServiceImpl implements TestService {

  4.     public String test() {

  5.         System.out.println("test success");

  6.         return "provider02";

  7.     }  

  8. }

  

provider01 :   TestServiceImpl.java实现公有接口 testService

[java] view plain copy

  1. package com.test.service;

  2. import com.test.service.TestService;

  3. public class TestServiceImpl implements TestService {

  4.     public String test() {

  5.         System.out.println("test success");

  6.         return "provider01";

  7.     }  

  8. }

  

2个provider,随意实现,返回效果不同就行了,因为后面要测试集群负载均衡效果

3.4 到这里提供者代码层面基本完了,该项目增加配置文件,在classpath目录下新建3个配置文件:applicationContext.xml(Spring配置文件),log4.properties,provider.xml(dubbo 提供者配置文件,重要)

applicationContext.xml:(2个provider一模一样)

[html] view plain copy

  1. <beans xmlns="http://www.springframework.org/schema/beans"

  2.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"

  3.     xmlns:p="http://www.springframework.org/schema/p" xmlns:aop="http://www.springframework.org/schema/aop"

  4.     xmlns:tx="http://www.springframework.org/schema/tx"

  5.     xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.3.xsd

  6.     http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.3.xsd   

  7.     http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.3.xsd   

  8.     http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.3.xsd"\>

  9.     <context:component-scan base-package="com.test" />

  10. </beans>

log4.properties:(2个provider一样)

[html] view plain copy

  1. log4j.appender.mylog = org.apache.log4j.ConsoleAppender

  2. log4j.appender.mylog.target = System.out

  3. log4j.appender.mylog.layout= org.apache.log4j.PatternLayout

  4. log4j.appender.mylog.layout.ConversionPattern=%-d{yyyy-MM-dd HH:mm:ss} [%c]-[%p] %m%n

  5. log4j.appender.my2log = org.apache.log4j.RollingFileAppender

  6. log4j.appender.my2log.File = D://Logger//mylog.log

  7. log4j.appender.my2log.MaxFileSize = 50KB

  8. log4j.appender.my2log.MaxBackupIndex = 1

  9. log4j.appender.my2log.layout= org.apache.log4j.PatternLayout

  10. log4j.appender.my2log.layout.ConversionPattern=%-d{yyyy-MM-dd HH:mm:ss} [%c]-[%p] %m%n

  11. log4j.rootLogger = info,mylog,my2log

provider01:    provider.xml

[html] view plain copy

  1. <beans xmlns="http://www.springframework.org/schema/beans"

  2.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

  3.     xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"

  4.     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"\>

  5.     

  6.     <dubbo:application name="provider"  />

  7.     

  8.     <dubbo:registry address="zookeeper://127.0.0.1:2181"/>

  9.     

  10.     <dubbo:protocol name="dubbo" port="20881" />

  11.     

  12.     

  13.     

  14.     <dubbo:service interface="com.test.service.TestService" ref="testService" />

  15. </beans>

provider02:    provider.xml

[html] view plain copy

  1. <beans xmlns="http://www.springframework.org/schema/beans"

  2.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"

  3.     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"\>

  4.     

  5.     <dubbo:application name="provider" />

  6.     

  7.     <dubbo:registry address="zookeeper://10.120.106.35:2181" />

  8.     

  9.     <dubbo:protocol name="dubbo" port="20882" />

  10.     

  11.     

  12.     

  13.     <dubbo:service interface="com.test.service.TestService" ref="testService" />

  14. </beans>

这里需要注意,2个provider的应用名,一样,因为模拟集群负载均衡,所以对Dubbo来说是一个服务。2个provider的端口需不一样,因为是同一台机子模拟2个服务,如果是多台就无所谓了。dubbo:Service须保持一致,因为2个provider负载均衡是模拟一个服务,所以提供的服务外面看来须一样。

3.5,业务代码以及配置文件都完成了,该启动2个provider了,新建provider类,并调用main启动,代码如下;

Provider.java(2个provider一样即可)

[html] view plain copy

  1. package com.test.provider;  

  2. import org.apache.log4j.PropertyConfigurator;  

  3. import org.springframework.context.support.ClassPathXmlApplicationContext;  

  4. public class Provider {  

  5.     // start provider  

  6.     static{  

  7.         PropertyConfigurator.configure("src/main/resources/log4.properties");  

  8.     }  

  9.     public static void main(String args[]) throws Exception {  

  10.         ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath*:/*.xml");

  11.         context.start();  

  12.         System.in.read();  

  13.     }  

  14. }

  

成功启动之后,显示注册到了zookeeper。

Dubbo+zookeeper构建高可用分布式集群(二)

这个时候我们刷新下dubbo.admin页面看看效果,显示提供者为1,说明一切正常

Dubbo+zookeeper构建高可用分布式集群(二)

然后启动第二个provider,至这里显示提供者为2,服务数为1,一切OK,下一步我们开始消费者端。

Dubbo+zookeeper构建高可用分布式集群(二)

第四步:创建消费者,这里创建2个Spring mvc web项目来充当消费的角色。

2个消费者(dubbo-consumer01,dubbo-consumer02)也一样,基本一样,就是服务实现不一样来测试负载均衡,还有个消费者配置文件不一样。

Dubbo+zookeeper构建高可用分布式集群(二)

4.1 2个消费者POM.xml基本是一样的,标准的Spring mvc web项目,需要引入dubbo,zookeeper,公有服务service,Spring mvc系列,log4系列。这里需要注意的是,dubbo的Spring实在过于老旧了,对于web项目来说是不合适的,遇到了版本冲突,所以需要剔除dubbo中依赖的spring2.5

pom.xml(copy请自行修改 groupId与artifactId):

[html]  view plain copy

  1. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

  2.   xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4\_0\_0.xsd"\>

  3.   <modelVersion>4.0.0</modelVersion>

  4.   <groupId>com.test</groupId>

  5.   <artifactId>dubbo-consumer02</artifactId>

  6.   <packaging>war</packaging>

  7.   <version>0.0.1-SNAPSHOT</version>

  8.   <name>customer02 Maven Webapp</name>

  9.   <url>http://maven.apache.org</url>

  10.     <properties>

  11.         <spring.version>4.3.8.RELEASE</spring.version>

  12.     </properties>

  13.     <dependencies>

  14.         <dependency>

  15.             <groupId>junit</groupId>

  16.             <artifactId>junit</artifactId>

  17.             <version>3.8.1</version>

  18.             <scope>test</scope>

  19.         </dependency>

  20.         <dependency>

  21.             <groupId>com.test</groupId>

  22.             <artifactId>service</artifactId>

  23.             <version>0.0.1-SNAPSHOT</version>

  24.         </dependency>

  25.         <dependency>

  26.             <groupId>com.alibaba</groupId>

  27.             <artifactId>dubbo</artifactId>

  28.             <version>2.5.3</version>

  29.             <exclusions>

  30.                 <exclusion>

  31.                     <artifactId>spring</artifactId>

  32.                     <groupId>org.springframework</groupId>

  33.                 </exclusion>

  34.             </exclusions>

  35.         </dependency>

  36.         

  37.         <dependency>

  38.             <groupId>org.springframework</groupId>

  39.             <artifactId>spring-webmvc</artifactId>

  40.             <version>${spring.version}</version>

  41.         </dependency>

  42.         <dependency>

  43.             <groupId>org.springframework</groupId>

  44.             <artifactId>spring-jdbc</artifactId>

  45.             <version>${spring.version}</version>

  46.         </dependency>

  47.         <dependency>

  48.             <groupId>org.springframework</groupId>

  49.             <artifactId>spring-context</artifactId>

  50.             <version>${spring.version}</version>

  51.         </dependency>

  52.         <dependency>

  53.             <groupId>org.springframework</groupId>

  54.             <artifactId>spring-aop</artifactId>

  55.             <version>${spring.version}</version>

  56.         </dependency>

  57.         <dependency>

  58.             <groupId>org.springframework</groupId>

  59.             <artifactId>spring-core</artifactId>

  60.             <version>${spring.version}</version>

  61.         </dependency>

  62.         <dependency>

  63.             <groupId>org.springframework</groupId>

  64.             <artifactId>spring-test</artifactId>

  65.             <version>${spring.version}</version>

  66.         </dependency>

  67.                 <dependency>

  68.             <groupId>org.springframework</groupId>

  69.             <artifactId>spring-test</artifactId>

  70.             <version>${spring.version}</version>

  71.         </dependency>

  72.         

  73.         

  74.         <dependency>

  75.             <groupId>javax.servlet</groupId>

  76.             <artifactId>javax.servlet-api</artifactId>

  77.             <version>3.0.1</version>

  78.             <scope>provided</scope>

  79.         </dependency>

  80.         <dependency>

  81.             <groupId>javax.servlet</groupId>

  82.             <artifactId>jstl</artifactId>

  83.             <version>1.1.2</version>

  84.             <scope>provided</scope>

  85.         </dependency>

  86.         <dependency>

  87.             <groupId>javax.servlet.jsp</groupId>

  88.             <artifactId>javax.servlet.jsp-api</artifactId>

  89.             <version>2.3.1</version>

  90.             <scope>provided</scope>

  91.         </dependency>

  92.         

  93.         <dependency>

  94.             <groupId>jstl</groupId>

  95.             <artifactId>jstl</artifactId>

  96.             <version>1.2</version>

  97.         </dependency>

  98.         <dependency>

  99.             <groupId>taglibs</groupId>

  100.             <artifactId>standard</artifactId>

  101.             <version>1.1.2</version>

  102.         </dependency>

  103.         

  104.         <dependency>

  105.             <groupId>org.codehaus.jackson</groupId>

  106.             <artifactId>jackson-jaxrs</artifactId>

  107.             <version>1.9.11</version>

  108.         </dependency>

  109.         

  110.         <dependency>

  111.             <groupId>org.apache.commons</groupId>

  112.             <artifactId>commons-lang3</artifactId>

  113.             <version>3.3.2</version>

  114.         </dependency>

  115.         <dependency>

  116.             <groupId>commons-io</groupId>

  117.             <artifactId>commons-io</artifactId>

  118.             <version>2.4</version>

  119.         </dependency>

  120.         <dependency>

  121.             <groupId>org.apache.commons</groupId>

  122.             <artifactId>commons-collections4</artifactId>

  123.             <version>4.0</version>

  124.         </dependency>

  125.         <dependency>

  126.             <groupId>commons-logging</groupId>

  127.             <artifactId>commons-logging</artifactId>

  128.             <version>1.1.3</version>

  129.         </dependency>

  130.         <dependency>

  131.             <groupId>commons-codec</groupId>

  132.             <artifactId>commons-codec</artifactId>

  133.             <version>1.8</version>

  134.         </dependency>

  135.         <dependency>

  136.             <groupId>commons-beanutils</groupId>

  137.             <artifactId>commons-beanutils</artifactId>

  138.             <version>1.8.3</version>

  139.         </dependency>

  140.         <dependency>

  141.             <groupId>commons-chain</groupId>

  142.             <artifactId>commons-chain</artifactId>

  143.             <version>1.2</version>

  144.         </dependency>

  145.         <dependency>

  146.             <groupId>commons-fileupload</groupId>

  147.             <artifactId>commons-fileupload</artifactId>

  148.             <version>1.3.1</version>

  149.         </dependency>

  150.         <dependency>

  151.             <groupId>org.apache.commons</groupId>

  152.             <artifactId>commons-math3</artifactId>

  153.             <version>3.3</version>

  154.         </dependency>

  155.         <dependency>

  156.             <groupId>org.apache.commons</groupId>

  157.             <artifactId>commons-pool2</artifactId>

  158.             <version>2.2</version>

  159.         </dependency>

  160.         <dependency>

  161.             <groupId>org.apache.commons</groupId>

  162.             <artifactId>commons-digester3</artifactId>

  163.             <version>3.2</version>

  164.         </dependency>

  165.         <dependency>

  166.             <groupId>commons-net</groupId>

  167.             <artifactId>commons-net</artifactId>

  168.             <version>3.3</version>

  169.         </dependency>

  170.         <dependency>

  171.             <groupId>commons-dbutils</groupId>

  172.             <artifactId>commons-dbutils</artifactId>

  173.             <version>1.5</version>

  174.         </dependency>

  175.         <dependency>

  176.             <groupId>org.apache.commons</groupId>

  177.             <artifactId>commons-email</artifactId>

  178.             <version>1.3.3</version>

  179.         </dependency>

  180.         <dependency>

  181.             <groupId>commons-dbcp</groupId>

  182.             <artifactId>commons-dbcp</artifactId>

  183.             <version>1.4</version>

  184.         </dependency>

  185.         

  186.         <dependency>

  187.             <groupId>log4j</groupId>

  188.             <artifactId>log4j</artifactId>

  189.             <version>1.2.16</version>

  190.         </dependency>

  191.         <dependency>

  192.             <groupId>org.slf4j</groupId>

  193.             <artifactId>slf4j-api</artifactId>

  194.             <version>1.7.5</version>

  195.         </dependency>

  196.         

  197.         <dependency>

  198.             <groupId>com.github.sgroschupf</groupId>

  199.             <artifactId>zkclient</artifactId>

  200.             <version>0.1</version>

  201.         </dependency>

  202.     </dependencies>

  203.     <build>

  204.         <finalName>dubbo-customer02</finalName>

  205.     </build>

  206. </project>

4.2,两个web项目的主要配置文件,共5个:web.xml、applicationContext.xml、consumer.xml、log4.properties、springmvc-servlet.xml。

web.xml :基本一样这里只放出一个

[html]  view plain copy

  1. <web-app version="2.5" xmlns="http://java.sun.com/xml/ns/javaee"

  2.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

  3.     xsi:schemaLocation="http://java.sun.com/xml/ns/javaee

  4.     http://java.sun.com/xml/ns/javaee/web-app\_2\_5.xsd"\>

  5.     <display-name>Archetype Created Web Application</display-name>

  6.     

  7.     <context-param>

  8.         <param-name>contextConfigLocation</param-name>

  9.         <param-value>classpath*:applicationContext.xml</param-value>

  10.     </context-param>

  11.     <listener>

  12.         <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>

  13.     </listener>

  14.     

  15.     <context-param>

  16.         <param-name>log4jConfigLocation</param-name>

  17.         <param-value>classpath:log4.properties</param-value>

  18.     </context-param>

  19.     <context-param>

  20.         <param-name>log4jRefreshInterval</param-name>

  21.         <param-value>3000</param-value>

  22.     </context-param>

  23.     <listener>

  24.         <listener-class>org.springframework.web.util.Log4jConfigListener</listener-class>

  25.     </listener>

  26.     

  27.     <filter>

  28.         <filter-name>encodingFilter</filter-name>

  29.         <filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>

  30.         <init-param>

  31.             <param-name>encoding</param-name>

  32.             <param-value>UTF-8</param-value>

  33.         </init-param>

  34.     </filter>

  35.     <filter-mapping>

  36.         <filter-name>encodingFilter</filter-name>

  37.         <url-pattern>/</url-pattern>

  38.     </filter-mapping>

  39.     

  40.     <servlet-mapping>

  41.         <servlet-name>default</servlet-name>

  42.         <url-pattern>*.jpg</url-pattern>

  43.     </servlet-mapping>

  44.     <servlet-mapping>

  45.         <servlet-name>default</servlet-name>

  46.         <url-pattern>*.png</url-pattern>

  47.     </servlet-mapping>

  48.     <servlet-mapping>

  49.         <servlet-name>default</servlet-name>

  50.         <url-pattern>*.js</url-pattern>

  51.     </servlet-mapping>

  52.     <servlet-mapping>

  53.         <servlet-name>default</servlet-name>

  54.         <url-pattern>*.css</url-pattern>

  55.     </servlet-mapping>

  56.     

  57.     

  58.     <servlet>

  59.         <servlet-name>springmvc</servlet-name>

  60.         <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>

  61.         <init-param>

  62.             <param-name>contextConfigLocation</param-name>

  63.             <param-value>classpath*:springmvc-servlet.xml</param-value>

  64.         </init-param>

  65.         <load-on-startup>1</load-on-startup>

  66.     </servlet>

  67.     <servlet-mapping>

  68.         <servlet-name>springmvc</servlet-name>

  69.         <url-pattern>/</url-pattern>

  70.     </servlet-mapping>

  71.     <welcome-file-list>

  72.         <welcome-file>index.jsp</welcome-file>

  73.     </welcome-file-list>

  74. </web-app>

applicationContext.xml    2个consumer一模一样,只是引入consumer消费者配置文件,很简单

[html]  view plain copy

  1. <beans xmlns="http://www.springframework.org/schema/beans"

  2.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"

  3.     xmlns:p="http://www.springframework.org/schema/p" xmlns:aop="http://www.springframework.org/schema/aop"

  4.     xmlns:tx="http://www.springframework.org/schema/tx"

  5.     xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.3.xsd

  6.     http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.3.xsd   

  7.     http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.3.xsd   

  8.     http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.3.xsd"\>

  9.     

  10. </beans>

consumer.xml:    消费者配置文件,这个很重要,这里消费者应用名不能一样了,因为我模拟是2个消费者,然后需要向zookeeper中心注册,还有个很重要的就是引用提供者提供的远程服务

consumer01:   consumer.xml

[html]  view plain copy

  1. <beans xmlns="http://www.springframework.org/schema/beans"

  2.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

  3.     xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"

  4.     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"\>

  5.     

  6.     <dubbo:application name="consumer01"  />

  7.     

  8.     <dubbo:registry address="zookeeper://127.0.0.1:2181"/>

  9.     

  10.     <dubbo:reference id="testService" interface="com.test.service.TestService" />

  11. </beans>

consumer02:   consumer.xml

[html]  view plain copy

  1. <beans xmlns="http://www.springframework.org/schema/beans"

  2.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

  3.     xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"

  4.     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"\>

  5.     

  6.     <dubbo:application name="consumer02"  />

  7.     

  8.     <dubbo:registry address="zookeeper://127.0.0.1:2181"/>

  9.     

  10.     <dubbo:reference id="testService" interface="com.test.service.TestService" />

  11. </beans>

log4配置文件,没什么好说的,同provider,这里不粘了

springmvc-servlet.xml :   配置文件,很简单,启用注解与controller扫描,没了。

[html]  view plain copy

  1. <beans xmlns="http://www.springframework.org/schema/beans"

  2.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"

  3.     xmlns:context="http://www.springframework.org/schema/context"

  4.     xmlns:mvc="http://www.springframework.org/schema/mvc"

  5.     xsi:schemaLocation="http://www.springframework.org/schema/beans    http://www.springframework.org/schema/beans/spring-beans-4.3.xsd

  6. http://www.springframework.org/schema/context    http://www.springframework.org/schema/context/spring-context-4.3.xsd   

  7. http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-4.3.xsd"  

  8.     default-lazy-init="true">

  9.     

  10.     <context:annotation-config />

  11.     

  12.     <context:component-scan base-package="com.test.controller" />

  13.     

  14.     <bean

  15.         class="org.springframework.web.servlet.mvc.annotation.AnnotationMethodHandlerAdapter" />

  16.     <bean

  17.         class="org.springframework.web.servlet.mvc.annotation.DefaultAnnotationHandlerMapping" />

  18.     <bean id="defaultViewResolver"

  19.         class="org.springframework.web.servlet.view.InternalResourceViewResolver"

  20.         p:order="3">

  21.         <property name="viewClass"

  22.             value="org.springframework.web.servlet.view.JstlView" />

  23.         

  24.         

  25.         

  26.     </bean>

  27. </beans>

4.3   spring mvc web 项目配置已经完成了,这一步,可以直接启动项目,启动成功,且能进helloworld 页则说明你的配置没有出现细微错误,否则需要检查检查,保证项目是正常的,不然后面排错懵逼。

现在我们新建个controller,很简单,就弄个接口,调用提供者的远程服务

consumer01:     TestController:   

[html]  view plain copy

[java]  view plain copy

  1. package com.test.controller;

  2. import java.util.Map;

  3. import javax.annotation.Resource;

  4. import org.springframework.stereotype.Controller;

  5. import org.springframework.web.bind.annotation.RequestMapping;

  6. import org.springframework.web.bind.annotation.ResponseBody;

  7. import com.test.service.TestService;

  8. /**

  9. * @author xianghui1

  10. *

  11. *         测试controller

  12. */

  13. @Controller

  14. public class TestController {

  15.     @Resource(name = "testService")

  16.     TestService testInterface;  

  17.     @RequestMapping(value = { "/consumer/testMain" })

  18.     @ResponseBody

  19.     public String testDubbo() {

  20.         return "consuemr01" + testInterface.test();

  21.     }  

  22. }

  

consumer02    TestController: 

[html]  view plain copy

  1. package com.test.controller;  

  2. import java.util.Map;  

  3. import javax.annotation.Resource;  

  4. import org.springframework.stereotype.Controller;  

  5. import org.springframework.web.bind.annotation.RequestMapping;  

  6. import org.springframework.web.bind.annotation.ResponseBody;  

  7. import com.test.service.TestService;  

  8. /**  

  9.  * @author xianghui1  

  10.  *  

  11.  *测试controller  

  12.  */  

  13. @Controller  

  14. public class TestController {  

  15.     @Resource(name="testService")

  16.     TestService testInterface;  

  17.     @RequestMapping(value={"/consumer/testMain"})

  18.     @ResponseBody  

  19.     public String testDubbo(){  

  20.         return "consuemr02"+testInterface.test();  

  21.     }  

  22. }

  

4.4,然后我们可以启动了,我们将2个consuemr分别放在两个tomcat中运行,2个tomcat端口要不一致的

可以看出2个consumer,2个provider,一切正常,我们在浏览器中访问我们的接口,也是正常

Dubbo+zookeeper构建高可用分布式集群(二) Dubbo+zookeeper构建高可用分布式集群(二)

第五步:到这里我们的dubbo+zookeeper+Spring mvc 搭建完成了,下一步,加入nginx 实现http层面的负载均衡

5.1   下载nginx,解压,并修改conf目录下的nginx.conf

5.2我们新建个upstream 负载均衡,采取默认的nginx负载均衡策略,然后监听80端口,将80端口所有的请求代理转发到负载上面

Dubbo+zookeeper构建高可用分布式集群(二)

5.3 命令行启动nginx,然后在浏览器中输入接口网址即可发现会出现四种结果,consumer01provider01、consumer02provider01、consumer01provider02、consumer02provider02.   dubbo+zookeeper+spring mvc+nginx负载均衡测试完成

--------------------------------------分割线 --------------------------------------

Ubuntu 14.04安装分布式存储Sheepdog+ZooKeeper  http://www.linuxidc.com/Linux/2014-12/110352.htm

CentOS 6安装sheepdog虚拟机分布式储存  http://www.linuxidc.com/Linux/2013-08/89109.htm

ZooKeeper集群配置 http://www.linuxidc.com/Linux/2013-06/86348.htm

使用ZooKeeper实现分布式共享锁http://www.linuxidc.com/Linux/2013-06/85550.htm

分布式服务框架 ZooKeeper -- 管理分布式环境中的数据http://www.linuxidc.com/Linux/2013-06/85549.htm

ZooKeeper集群环境搭建实践 http://www.linuxidc.com/Linux/2013-04/83562.htm

ZooKeeper服务器集群环境配置实测 http://www.linuxidc.com/Linux/2013-04/83559.htm

ZooKeeper集群安装 http://www.linuxidc.com/Linux/2012-10/72906.htm

点赞
收藏
评论区
推荐文章
blmius blmius
3年前
MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1
文章目录问题用navicat导入数据时,报错:原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。全局s
皕杰报表之UUID
​在我们用皕杰报表工具设计填报报表时,如何在新增行里自动增加id呢?能新增整数排序id吗?目前可以在新增行里自动增加id,但只能用uuid函数增加UUID编码,不能新增整数排序id。uuid函数说明:获取一个UUID,可以在填报表中用来创建数据ID语法:uuid()或uuid(sep)参数说明:sep布尔值,生成的uuid中是否包含分隔符'',缺省为
待兔 待兔
3个月前
手写Java HashMap源码
HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程22
Jacquelyn38 Jacquelyn38
3年前
2020年前端实用代码段,为你的工作保驾护航
有空的时候,自己总结了几个代码段,在开发中也经常使用,谢谢。1、使用解构获取json数据let jsonData  id: 1,status: "OK",data: 'a', 'b';let  id, status, data: number   jsonData;console.log(id, status, number )
Wesley13 Wesley13
3年前
Java获得今日零时零分零秒的时间(Date型)
publicDatezeroTime()throwsParseException{    DatetimenewDate();    SimpleDateFormatsimpnewSimpleDateFormat("yyyyMMdd00:00:00");    SimpleDateFormatsimp2newS
Stella981 Stella981
3年前
KVM调整cpu和内存
一.修改kvm虚拟机的配置1、virsheditcentos7找到“memory”和“vcpu”标签,将<namecentos7</name<uuid2220a6d1a36a4fbb8523e078b3dfe795</uuid
Wesley13 Wesley13
3年前
mysql设置时区
mysql设置时区mysql\_query("SETtime\_zone'8:00'")ordie('时区设置失败,请联系管理员!');中国在东8区所以加8方法二:selectcount(user\_id)asdevice,CONVERT\_TZ(FROM\_UNIXTIME(reg\_time),'08:00','0
Wesley13 Wesley13
3年前
00:Java简单了解
浅谈Java之概述Java是SUN(StanfordUniversityNetwork),斯坦福大学网络公司)1995年推出的一门高级编程语言。Java是一种面向Internet的编程语言。随着Java技术在web方面的不断成熟,已经成为Web应用程序的首选开发语言。Java是简单易学,完全面向对象,安全可靠,与平台无关的编程语言。
Stella981 Stella981
3年前
Django中Admin中的一些参数配置
设置在列表中显示的字段,id为django模型默认的主键list_display('id','name','sex','profession','email','qq','phone','status','create_time')设置在列表可编辑字段list_editable
Wesley13 Wesley13
3年前
MySQL部分从库上面因为大量的临时表tmp_table造成慢查询
背景描述Time:20190124T00:08:14.70572408:00User@Host:@Id:Schema:sentrymetaLast_errno:0Killed:0Query_time:0.315758Lock_
Python进阶者 Python进阶者
9个月前
Excel中这日期老是出来00:00:00,怎么用Pandas把这个去除
大家好,我是皮皮。一、前言前几天在Python白银交流群【上海新年人】问了一个Pandas数据筛选的问题。问题如下:这日期老是出来00:00:00,怎么把这个去除。二、实现过程后来【论草莓如何成为冻干莓】给了一个思路和代码如下:pd.toexcel之前把这