Dubbo is integrated with Zookeeper and Spring

Dubbo uses a full Spring configuration mode to transparently access applications without any API intrusion. You only need to load Dubbo’s configuration with Spring. Dubbo is loaded based on Spring’s Schema extension.

1: Single-machine deployment mode ZooKeeper is installed

1, download the zookeeper registry, download address: www.apache.org/dyn/closer…. E:\zookeeper-3.3.6\zookeeper-3.3.6\bin,

Double-click zkServer.cmd to start the registry service.

Zkserver. sh [Linux] or zkserver. CMD [Windows]

The Zookeeper configuration file is in the conf directory. This directory contains zoo_sample. CFG and log4j.properties. All you need to do is rename zoo_sample. CFG to zoo.cfg because Zookeeper looks for this file as the default configuration file when it starts. The following details the meaning of each configuration item in this configuration file.

•tickTime: Indicates the heartbeat interval between Zookeeper servers or between clients and servers. That is, each tickTime sends a heartbeat.

•dataDir: Indicates the directory in which Zookeeper saves data. By default, Zookeeper saves log files that write data in this directory.

•dataLogDir: Indicates the directory where Zookeeper saves log files

•clientPort: This port is used by the client to connect to the Zookeeper server. Zookeeper listens to this port and receives access requests from the client

After the configuration, ZooKeeper listens on port 2181 of the local host.

After these configuration items are configured, you can now start Zookeeper. To check whether Zookeeper is already in service, run the netstat -ano command to check whether the clientPort number you configured is listening for the service.

Two: service providers

Define the service interface :(this interface needs to be packaged separately and shared between service providers and consumers)

[java]
view plain
copy

print
?

  1. package com.unj.dubbotest.provider;
  3. import java.util.List;
  5. public interface DemoService {
  7. String sayHello(String name);
  9. public List getUsers();
  11. }

Implement interface at service provider :(hide implementation from service consumer)

[java]
view plain
copy


  1. package com.unj.dubbotest.provider.impl;
  3. import java.util.ArrayList;
  4. import java.util.List;
  6. import com.unj.dubbotest.provider.DemoService;
  8. public class DemoServiceImpl implements DemoService {
  10. public String sayHello(String name) {
  11. return “Hello ” + name;
  12. }
  14. public List getUsers() {
  15. List list = new ArrayList();
  16. User u1 = new User();
  17. u1.setName(“hejingyuan”);
  18. u1.setAge(20);
  19. u1.setSex(“f”);
  21. User u2 = new User();
  22. u2.setName(“xvshu”);
  23. u2.setAge(21);
  24. u2.setSex(“m”);
  27. list.add(u1);
  28. list.add(u2);
  30. return list;
  31. }
  32. }

Exposing services with Spring configuration declarations:

[html]
view plain
copy

print
?

  2. <beans xmlns=”http://www.springframework.org/schema/beans”
  3. xmlns:xsi=”http://www.w3.org/2001/XMLSchema-instance” xmlns:dubbo=”http://code.alibabatech.com/schema/dubbo”
  4. xsi:schemaLocation=”http://www.springframework.org/schema/beans
  5. http://www.springframework.org/schema/beans/spring-beans.xsd
  6. http://code.alibabatech.com/schema/dubbo
  7. http://code.alibabatech.com/schema/dubbo/dubbo.xsd
  8. “>
  10. <! — Specific implementation bean –>
  11. <bean id=”demoService” class=”com.unj.dubbotest.provider.impl.DemoServiceImpl” />
  13. <! — Provider application information for calculating dependencies –>
  14. <dubbo:application name=”xs_provider” />
  16. <! Use multicast broadcast registries to expose service addresses
  17. <! – “dubbo: registry address =” multicast: / / 224.5.6.7:1234 “/ > — >
  19. <! Use the ZooKeeper registry to expose the service address — that is, the IP address and port number of the zooKeeper server –>
  20. “Dubbo: registry address =” zookeeper: / / 192.168.24.213:2181 “/ >
  22. <! Expose service on port 20880 with dubbo
  23. <dubbo:protocol name=”dubbo” port=”20880″ />
  25. <! Declare the service interface to be exposed –>
  26. <dubbo:service interface=”com.unj.dubbotest.provider.DemoService”
  27. ref=”demoService” />
  29. </beans>

Load the Spring configuration and start the service (or build the project as a Web project, configure the Spring startup in web.xml, and throw it into Tomcat to provide the service) :

[java]
view plain
copy


  1. package com.unj.dubbotest.provider.impl;
  3. import org.springframework.context.support.ClassPathXmlApplicationContext;
  5. public class Provider {
  7. public static void main(String[] args) throws Exception {
  8. ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
  9. new String[] { “applicationContext.xml” });
  10. context.start();
  11. System.in.read(); // To keep the service on, use the blocking of the input stream to simulate
  12. }
  13. }

Three: service consumers

Referencing remote services via Spring configuration:

[html]
view plain
copy


  2. <beans xmlns=”http://www.springframework.org/schema/beans”
  3. xmlns:xsi=”http://www.w3.org/2001/XMLSchema-instance” xmlns:dubbo=”http://code.alibabatech.com/schema/dubbo”
  4. xsi:schemaLocation=”http://www.springframework.org/schema/beans
  5. http://www.springframework.org/schema/beans/spring-beans.xsd
  6. http://code.alibabatech.com/schema/dubbo
  7. http://code.alibabatech.com/schema/dubbo/dubbo.xsd
  8. “>
  10. <! — Consumer application name, used to calculate dependencies, not matching conditions, not the same as provider –>
  11. <dubbo:application name=”hjy_consumer” />
  13. <! — Use zooKeeper registry to expose service address –>
  14. <! – “dubbo: registry address =” multicast: / / 224.5.6.7:1234 “/ > — >
  15. “Dubbo: registry address =” zookeeper: / / 192.168.24.213:2181 “/ >
  17. <! Create a remote service proxy that can be used as a local bean –>
  18. <dubbo:reference id=”demoService”
  19. interface=”com.unj.dubbotest.provider.DemoService” />
  21. </beans>

Calling the service test:

[java]
view plain
copy


  1. package com.alibaba.dubbo.demo.pp;
  3. import java.util.List;
  5. import org.springframework.context.support.ClassPathXmlApplicationContext;
  7. import com.unj.dubbotest.provider.DemoService;
  9. public class Consumer {
  11. public static void main(String[] args) throws Exception {
  12. ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
  13. new String[] { “applicationContext.xml” });
  14. context.start();
  16. DemoService demoService = (DemoService) context.getBean(“demoService”);
  17. String hello = demoService.sayHello(“hejingyuan”);
  18. System.out.println(hello);
  20. List list = demoService.getUsers();
  21. if (list ! = null && list.size() > 0) {
  22. for (int i = 0; i < list.size(); i++) {
  23. System.out.println(list.get(i));
  24. }
  25. }
  26. System.in.read();
  27. }
  29. }

Test results:

Complete project source code

Willing to understand the framework technology or source code of friends directly ask to exchange technology: 2042849237

J2ee distributed architecture, restful, kafka, shiro, Spring MVC, mybatis, redis, dubbo, zookeeper

J2ee Distributed Architecture, restful, Shiro, Spring MVC, Mybatis, Redis, Dubbo, ZooKeeper