dubbo学习_不写bug的程序媛_dubbo学习

irpas 02-07 5020

1.zookeeper下载安装到官网下载，我下的3.4.11版本下载地址：链接：https://pan.baidu.com/s/1zJEi_qJJMD86Bs-vAqtIFw? 提取码：aj1n 1.1 如下图

? 1.2修改配置文件 1.3在zookeeper的bin目录下启动cmd执行命令zkServer.cmd启动zookeeper. ? 报错JAVA_HOME is not set 和 JAVA_HOME is incorrectly set. ??直接把jdk写死如下：

?2.到dubbo官网下载dubbo-admin控制台。用maven方式运行下载地址：链接：https://pan.baidu.com/s/17yy_gE_qfD5ew4JUDlu7zw? 提取码：gzk8

?然后在dubbo-admin目录下启动cmd, 执行命令mvn clean package打包，打好包后会在target目录下，在当前目录(也可以把包复制到别的目录)执行java -jar dubbo-admin-0.0.1-SNAPSHOT.jar

端口号为7001, 在浏览器上打输入?http://localhost:7001/?帐号和密码都是root 以下是代码：公共接口在一个项目中单独的：

UserAddress.java类： ?

package com.atguigu.gmall.bean; import java.io.Serializable; /** * 用户地址 * @author lfy * */ public class UserAddress implements Serializable { private Integer id; private String userAddress; //用户地址 private String userId; //用户id private String consignee; //收货人 private String phoneNum; //电话号码 private String isDefault; //是否为默认地址 Y-是 N-否 public UserAddress() { super(); // TODO Auto-generated constructor stub } public UserAddress(Integer id, String userAddress, String userId, String consignee, String phoneNum, String isDefault) { super(); this.id = id; this.userAddress = userAddress; this.userId = userId; this.consignee = consignee; this.phoneNum = phoneNum; this.isDefault = isDefault; } public Integer getId() { return id; } public void setId(Integer id) { this.id = id; } public String getUserAddress() { return userAddress; } public void setUserAddress(String userAddress) { this.userAddress = userAddress; } public String getUserId() { return userId; } public void setUserId(String userId) { this.userId = userId; } public String getConsignee() { return consignee; } public void setConsignee(String consignee) { this.consignee = consignee; } public String getPhoneNum() { return phoneNum; } public void setPhoneNum(String phoneNum) { this.phoneNum = phoneNum; } public String getIsDefault() { return isDefault; } public void setIsDefault(String isDefault) { this.isDefault = isDefault; } }

OrderService.java:

package com.atguigu.gmall.service; import java.util.List; import com.atguigu.gmall.bean.UserAddress; public interface OrderService { /** * 初始化订单 * @param userId */ public List<UserAddress> initOrder(String userId); }

UserService.java: ?

package com.atguigu.gmall.service; import java.util.List; import com.atguigu.gmall.bean.UserAddress; /** * 用户服务 * @author lfy * */ public interface UserService { /** * 按照用户id返回所有的收货地址 * @param userId * @return */ public List<UserAddress> getUserAddressList(String userId); }

?提供者代码示例(就是提供服务的生产者)： UserServiceImpl.java:

package com.my.service.impl; import com.atguigu.gmall.bean.UserAddress; import com.atguigu.gmall.service.UserService; import java.util.Arrays; import java.util.List; public class UserServiceImpl implements UserService { @Override public List<UserAddress> getUserAddressList(String userId) { System.out.println("UserServiceImpl.....old..."); UserAddress address1 = new UserAddress(1, "北京市昌平区宏福科技园综合楼3层", "1", "李老师", "010-56253825", "Y"); UserAddress address2 = new UserAddress(2, "深圳市宝安区西部硅谷大厦B座3层（深圳分校）", "1", "王老师", "010-56253825", "N"); return Arrays.asList(address1,address2); } }

provider.xml:

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://·/schema/dubbo" xsi:schemaLocation="http://·/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">  <dubbo:application name="user-service-provider"></dubbo:application>   <dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"></dubbo:registry>  <dubbo:protocol name="dubbo" port="20882"></dubbo:protocol>  <dubbo:service interface="com.atguigu.gmall.service.UserService" ref="UserServiceImpl" timeout="1000" version="1.0.0">  </dubbo:service>  <bean id="UserServiceImpl" class="com.my.service.impl.UserServiceImpl"></bean>  <dubbo:monitor protocol="registry"></dubbo:monitor>   </beans>

?pom.xml:

<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://·piler.source>1.8</maven.compiler.source> <maven.compiler.target>1.8</maven.compiler.target> </properties> <groupId>com.service.provider</groupId> <artifactId>my-service-provider-dubbo</artifactId> <version>1.0-SNAPSHOT</version> <dependencies>   <dependency> <groupId>com.alibaba</groupId> <artifactId>dubbo</artifactId> <version>2.6.2</version> </dependency>  <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-framework</artifactId> <version>2.12.0</version> </dependency> </dependencies> </project>

MainApplication .java:

import org.springframework.context.support.ClassPathXmlApplicationContext; import java.io.IOException; public class MainApplication { public static void main(String[] args) throws IOException { ClassPathXmlApplicationContext ioc = new ClassPathXmlApplicationContext("provider.xml"); ioc.start(); System.in.read(); } }

注意：先启动服务者，把服务者注册到注册中心，才启动消费者消费者示例代码：

OrderServiceImpl.java: package com.ou.service.impl; import com.atguigu.gmall.bean.UserAddress; import com.atguigu.gmall.service.OrderService; import com.atguigu.gmall.service.UserService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.List; @Service public class OrderServiceImpl implements OrderService { @Autowired UserService userService; @Override public List<UserAddress> initOrder(String userId) { System.out.println("用户id："+userId); //1、查询用户的收货地址 List<UserAddress> addressList = userService.getUserAddressList(userId); for (UserAddress userAddress : addressList) { System.out.println(userAddress.getUserAddress()); } return addressList; } }

consumer.xml:

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://·/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd"> <context:component-scan base-package="com.ou.service.impl"></context:component-scan> <dubbo:application name="order-service-consumer"></dubbo:application> <dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry>       <dubbo:reference interface="com.atguigu.gmall.service.UserService" id="userService" timeout="5000" retries="3" version="*">  </dubbo:reference>  <dubbo:consumer check="false" timeout="5000"></dubbo:consumer>  <dubbo:monitor protocol="registry"></dubbo:monitor>   </beans> MainApplication.java: import java.io.IOException; import org.springframework.context.support.ClassPathXmlApplicationContext; import com.atguigu.gmall.service.OrderService; public class MainApplication { public static void main(String[] args) throws IOException { ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("consumer.xml"); OrderService orderService = applicationContext.getBean(OrderService.class); orderService.initOrder("1"); System.out.println("调用完成...."); System.in.read(); } }

?pom.xml:

<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://·piler.source>1.8</maven.compiler.source> <maven.compiler.target>1.8</maven.compiler.target> </properties> <groupId>com.order.consumer</groupId> <artifactId>order-service-consumer</artifactId> <version>1.0-SNAPSHOT</version> <dependencies>   <dependency> <groupId>com.alibaba</groupId> <artifactId>dubbo</artifactId> <version>2.6.2</version> </dependency>  <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-framework</artifactId> <version>2.12.0</version> </dependency> </dependencies> </project>

?先启动提供者，在启动消费者，在dubbo的控制台可以看到：

?接下来启动监控中心：之前在官网下载的dubbo-admin里有一个dubbo-monitor-simple文件夹，在这个目录里执行命令mvn clean package打包命令，然后将打好的jar包变成压缩包，在把压缩包解压，把里面的conf/dubbo.properties里的dubbo.registry.address和dubbo.protocol.port都改成自己的，然后执行assembly.bin文件夹里的start启动

?基于Spring boot的服务提供者代码： application.prperties:

dubbo.application.name=user-service-provider dubbo.registry.address=127.0.0.1:2181 dubbo.registry.protocol=zookeeper #指定通信规则(通信协议，通信端口) dubbo.protocol.name=dubbo dubbo.protocol.port=20880 dubbo.monitor.protocol=registry UserServiceImpl.java: package com.atguigu.gmall.service.impl; import java.util.Arrays; import java.util.List; import org.springframework.stereotype.Component; import com.alibaba.dubbo.config.annotation.Service; import com.atguigu.gmall.bean.UserAddress; import com.atguigu.gmall.service.UserService; @Service//暴露服务是dubbo的api,由原来在xml里写的dubbo:service现在只要一个注解 @Component public class UserServiceImpl implements UserService { //@HystrixCommand @Override public List<UserAddress> getUserAddressList(String userId) { // TODO Auto-generated method stub System.out.println("UserServiceImpl..3....."); UserAddress address1 = new UserAddress(1, "北京市昌平区宏福科技园综合楼3层", "1", "李老师", "010-56253825", "Y"); UserAddress address2 = new UserAddress(2, "深圳市宝安区西部硅谷大厦B座3层（深圳分校）", "1", "王老师", "010-56253825", "N"); if(Math.random()>0.5) { throw new RuntimeException(); } return Arrays.asList(address1,address2); } }

application.java运行类：

@EnableDubbo(scanBasePackages="com.atguigu.gmall") @SpringBootApplication public class BootUserServiceProviderApplication { public static void main(String[] args) { SpringApplication.run(BootUserServiceProviderApplication.class, args); } }

?pom.xml：

<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://`flix.hystrix.contrib.javanica.annotation.HystrixCommand; /** * 1、将服务提供者注册到注册中心（暴露服务） * 1）、导入dubbo依赖（2.6.2）\操作zookeeper的客户端(curator) * 2）、配置服务提供者 * * 2、让服务消费者去注册中心订阅服务提供者的服务地址 * */ @Service public class OrderServiceImpl implements OrderService { //@Autowired @Reference //替代之前xml里的 dubbo:reference UserService userService; @HystrixCommand(fallbackMethod="hello") @Override public List<UserAddress> initOrder(String userId) { // TODO Auto-generated method stub System.out.println("用户id："+userId); //1、查询用户的收货地址 List<UserAddress> addressList = userService.getUserAddressList(userId); return addressList; } }

pom.xml和提供者是一样的。 appcation.java类：

package com.atguigu.gmall; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.netflix.hystrix.EnableHystrix; import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo; @EnableDubbo //@EnableHystrix @SpringBootApplication public class BootOrderServiceConsumerApplication { public static void main(String[] args) { SpringApplication.run(BootOrderServiceConsumerApplication.class, args); } }