dubbo学习例题代码资源

package com.dubbo.dubboorderservice.service; import com.dubbo.dubbointerfaces.bean.UserAddress; import com.dubbo.dubbointerfaces.service.OrderService; import com.dubbo.dubbointerfaces.service.UserService; import org.apache.dubbo.config.annotation.Reference; import org.apache.dubbo.rpc.service.GenericService; import org.springframework.context.support.ClassPathXmlApplicationContext; import org.springframework.stereotype.Service; import java.io.IOException; import java.util.List; /** * @author 江涛 * @date 2022/4/5 */ @Service public class OrderServiceImpl implements OrderService { //注入远程服务:服务提供者如果设定了版本号那么，消费者一定要制定对应的版本号，不然找不到服务 @Reference(version = "1.0.0",stub = "false" ,loadbalance = "random") UserService userService; //出错的回调方法(hystrix依赖引入出问题，暂时先就不搞了) // @HystrixCommand(fallbackMethod = "errorMethod") @Override public void initOrder(String userId) { //调用远程服务方法：获取用户地址 List<UserAddress> userAddressList = userService.getUserAddressList(userId); userAddressList.forEach(System.out::println); //泛化调用 // genericService(); System.out.println("调用结束"); //让进程阻塞，否则直接结束的话就看不到提供者上线 try { System.in.read(); } catch (IOException e) { e.printStackTrace(); } } public String errorMethod() { return "error"; } public String genericService(){ //泛化调用，根据配置文件获取applicationContext（搞不通 ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext(""); GenericService MyGenericServiceImpl = (GenericService) applicationContext.getBean("MyGenericServiceImpl"); Object result = MyGenericServiceImpl.$invoke("generciMethod" , new String[] { "java.lang.String" }, new Object[] { "1" }); System.out.println(result); return "ok"; } }