服务提供和消费脑图

@RestController@RequestMapping("index")public class IndexController {    @Autowired    private RedisCacheTemplate redisCacheTemplate;　　 //注册服务提供者信息，将信息放到redis中    @RequestMapping(value = "register", method = RequestMethod.POST)    public SimpleResponse register(@RequestBody RegisterMessage registerMessage) {        try {            Map
     
       map = new HashMap<>();            for (InterfaceMessage interfaceMessage : registerMessage.getInterfaceMessageList()) {                interfaceMessage.setProviderUrl(registerMessage.getProviderUrl());                map.put(ToStringBuilder.reflectionToString(interfaceMessage, ToStringStyle.SHORT_PREFIX_STYLE), true);            }            redisCacheTemplate.batchPut(map);            return SimpleResponse.success(map.size());        } catch (Exception e) {            e.printStackTrace();            return SimpleResponse.error(e.getMessage());        }    }　　 //消费者拿到配置的服务信息到注册中心来匹配，验证是否存在这个服务    @RequestMapping(value = "contains", method = RequestMethod.POST)    public SimpleResponse contains(@RequestBody InterfaceMessage interfaceMessage) {        try {            if(redisCacheTemplate.exist(ToStringBuilder.reflectionToString(interfaceMessage, ToStringStyle.SHORT_PREFIX_STYLE))) {                return SimpleResponse.success(true);            } else {                return SimpleResponse.error(null);            }        } catch (Exception e) {            e.printStackTrace();            return SimpleResponse.error(e.getMessage());        }    }    @RequestMapping(value = "test", method = {RequestMethod.GET, RequestMethod.POST})    public SimpleResponse test(@RequestParam String providerUrl){        return SimpleResponse.success(providerUrl);    }}
     

# 内置tomcat服务器配置server.port=8088server.context-path=/provider-server#打印彩色日志spring.output.ansi.enabled=always# 日志打印级别logging.level.root=debug# serviceservice.xml.path=classpath:service-provider.xml 自定义服务提供者配置文件 位置service.provider.path=http://localhost:8088/provider-server/index/provider  服务提供者执行相应服务接口service.register.path=http://localhost:8090/register-server/index/register  调用注册中心 接口

import com.alibaba.fastjson.JSON;import com.alibaba.fastjson.JSONObject;import com.hjzgg.simulation.common.node.InterfaceMessage;import com.hjzgg.simulation.common.node.RegisterMessage;import com.hjzgg.simulation.common.parsexml.BeanNode;import com.hjzgg.simulation.common.parsexml.ParseServiceXML;import com.hjzgg.simulation.common.response.ReturnCode;import com.hjzgg.simulation.common.utils.RestTemplateUtils;import org.apache.commons.lang3.StringUtils;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.beans.factory.support.BeanDefinitionRegistry;import org.springframework.context.EnvironmentAware;import org.springframework.context.annotation.ImportBeanDefinitionRegistrar;import org.springframework.core.env.Environment;import org.springframework.core.type.AnnotationMetadata;import org.springframework.http.MediaType;import org.springframework.util.CollectionUtils;import java.util.ArrayList;import java.util.List;public class Registrar implements ImportBeanDefinitionRegistrar, EnvironmentAware {    private static Logger logger = LoggerFactory.getLogger(Registrar.class);    private String servicesXmlPath;    private String serviceProviderPath;    private String serviceRegisterPath;    @Override    public void registerBeanDefinitions(AnnotationMetadata importingClassMetadata, BeanDefinitionRegistry registry) {        List
     
       beanNodes = ParseServiceXML.getProviderServices(servicesXmlPath); 解析自定义服务提供配置文件        List
      
        list = new ArrayList<>();        for(BeanNode beanNode : beanNodes) {
     根据服务对应id去 寻找实现的 bean            if(!registry.containsBeanDefinition(beanNode.getBeanName())) {                logger.error("接口" + beanNode.getBeanName() + " " + beanNode.getInterfaceCls().getTypeName() + " 没有对应的实现类");            } else {                InterfaceMessage interfaceMessage = new InterfaceMessage();                interfaceMessage.setBeanName(beanNode.getBeanName());                interfaceMessage.setInterfacType(beanNode.getInterfaceCls().getTypeName());                list.add(interfaceMessage);            }        }        if(!CollectionUtils.isEmpty(list)) { 将配置的服务信息发送的注册中心            RegisterMessage registerMessage = new RegisterMessage();            registerMessage.setProviderUrl(this.serviceProviderPath);            registerMessage.setInterfaceMessageList(list);            try {                String result = RestTemplateUtils.post(this.serviceRegisterPath, (JSONObject) JSON.toJSON(registerMessage), MediaType.APPLICATION_JSON_UTF8);                JSONObject retJson = JSONObject.parseObject(result);                if(retJson.getInteger("code") == ReturnCode.SUCCESS.getValue()) {                    logger.debug("服务注册成功...");                } else {                    logger.error("服务注册失败..." + retJson.getString("msg"));                }            } catch (Exception e) {                e.printStackTrace();                logger.error("服务注册失败..." + e.getMessage());            }        }    }    @Override    public void setEnvironment(Environment environment) { 获取环境变量        this.servicesXmlPath = environment.getProperty("service.xml.path");        this.serviceProviderPath = environment.getProperty("service.provider.path");        this.serviceRegisterPath = environment.getProperty("service.register.path");        assert(StringUtils.isNotEmpty(this.serviceProviderPath) && StringUtils.isNotEmpty(serviceRegisterPath) &&        StringUtils.isNotEmpty(this.servicesXmlPath));    }}
      
     

import org.springframework.context.annotation.Configuration;import org.springframework.context.annotation.Import;/** * Created by hujunzheng on 2017/7/7. */@Configuration@Import(Registrar.class)public class Config {
     注册服务配置启动}

import com.hjzgg.simulation.common.node.ServiceMessage;import com.hjzgg.simulation.common.response.SimpleResponse;import com.hjzgg.simulation.common.utils.ContextUtils;import com.hjzgg.simulation.common.utils.SerializeUtil;import org.apache.commons.codec.binary.Hex;import org.apache.commons.lang3.builder.ToStringBuilder;import org.springframework.util.ReflectionUtils;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RequestMethod;import org.springframework.web.bind.annotation.RequestParam;import org.springframework.web.bind.annotation.RestController;import java.lang.reflect.Method;import java.util.ArrayList;import java.util.List;/** * Created by hujunzheng on 2017/7/8. */@RestController@RequestMapping("index")public class IndexController { 　　 服务提供者执行相应服务接口    @RequestMapping(value = "invoke", method = RequestMethod.POST)    public Object invoke(@RequestParam String serviceMessageBody) {        try {
    　　　　　　　根据消费者传递的服务信息 找到对应的服务bean以及方法，并利用反射执行方法，最后返回结果            ServiceMessage serviceMessage = (ServiceMessage) SerializeUtil.unserialize(Hex.decodeHex(serviceMessageBody.toCharArray()));            Object bean = null;            if((bean = ContextUtils.getBean(serviceMessage.getBeanName(), serviceMessage.getRequireType())) != null) {                List
     
      > classList = new ArrayList<>();                if(serviceMessage.getArgs() != null) {                    for (Object obj : serviceMessage.getArgs()) {                        classList.add(obj.getClass());                    }                }                Method method = ReflectionUtils.findMethod(bean.getClass(), serviceMessage.getMethodName(), classList.toArray(new Class
      [0]));                if(method != null) {                    return method.invoke(bean, serviceMessage.getArgs());                } else {                    return SimpleResponse.error("服务" + serviceMessage.getRequireType().getTypeName() + "中没有对应参数"                            + ToStringBuilder.reflectionToString(classList) + "的" + serviceMessage.getMethodName() + "方法");                }            } else {                return SimpleResponse.error("没有名称为" + serviceMessage.getBeanName() + "且类型为"                        + serviceMessage.getRequireType().getTypeName() + "对应的bean");            }        } catch (Exception e) {            e.printStackTrace();            return SimpleResponse.error(e.getMessage());        }    }}
     

# 内置tomcat服务器配置server.port=8089server.context-path=/consumer-server#打印彩色日志spring.output.ansi.enabled=always# 日志打印级别logging.level.root=debug# service xmlservice.xml.path=classpath:service-consumer.xml 自定义服务消费配置文件位置service.contains.url=http://localhost:8090/register-server/index/contains 注册中心服务查询接口service.invoke.url=http://localhost:8088/provider-server/index/invoke 服务提供者执行相应服务接口

import com.alibaba.fastjson.JSON;import com.alibaba.fastjson.JSONObject;import com.hjzgg.simulation.common.dynamic.JdkDynamicProxy;import com.hjzgg.simulation.common.node.InterfaceMessage;import com.hjzgg.simulation.common.parsexml.BeanNode;import com.hjzgg.simulation.common.parsexml.ParseServiceXML;import com.hjzgg.simulation.common.register.SpringBeanRegister;import com.hjzgg.simulation.common.response.ReturnCode;import com.hjzgg.simulation.common.utils.RestTemplateUtils;import org.apache.commons.lang3.StringUtils;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.beans.factory.support.BeanDefinitionRegistry;import org.springframework.context.EnvironmentAware;import org.springframework.context.annotation.ImportBeanDefinitionRegistrar;import org.springframework.core.env.Environment;import org.springframework.core.type.AnnotationMetadata;import org.springframework.http.MediaType;import java.util.Iterator;import java.util.List;public class Registrar implements ImportBeanDefinitionRegistrar, EnvironmentAware{    private Logger logger = LoggerFactory.getLogger(Registrar.class);    private String servicesXmlPath;    private String serviceContainsPath;    @Override    public void registerBeanDefinitions(AnnotationMetadata importingClassMetadata, BeanDefinitionRegistry registry) {
    　　　　　解析自定义服务消费配置文件        List
     
       beanNodes = ParseServiceXML.getConsumerServices(servicesXmlPath);        判断注册中心 是否注册了这个服务了        for(Iterator
      
        it = beanNodes.iterator(); it.hasNext(); ) {            BeanNode beanNode = it.next();            InterfaceMessage interfaceMessage = new InterfaceMessage();            interfaceMessage.setProviderUrl(beanNode.getUrl());            interfaceMessage.setInterfacType(beanNode.getInterfaceCls().getTypeName());            interfaceMessage.setBeanName(beanNode.getBeanName());            try {                String result = RestTemplateUtils.post(this.serviceContainsPath, (JSONObject) JSON.toJSON(interfaceMessage), MediaType.APPLICATION_JSON_UTF8);                JSONObject retJson = JSON.parseObject(result);                if (retJson.getInteger("code") == ReturnCode.FAILURE.getValue()) {                    it.remove();                    logger.error(interfaceMessage.getBeanName() + "对应类型" + interfaceMessage.getInterfacType() + "的服务在" +                    interfaceMessage.getProviderUrl() + "上没有注册");                }            } catch (Exception e) {                e.printStackTrace();                logger.error("服务" + interfaceMessage.getBeanName() + "对应类型" + interfaceMessage.getInterfacType() + "查找失败..." + e.getMessage());            }        } 　　　　 将与注册中心一直的服务 以 动态代理的方式 注册到spring中        SpringBeanRegister.registerBean(importingClassMetadata, registry, beanNodes);    }    @Override    public void setEnvironment(Environment environment) { 设置环境变量        this.servicesXmlPath = environment.getProperty("service.xml.path");        this.serviceContainsPath = environment.getProperty("service.contains.url");        String serviceInvokePath = environment.getProperty("service.invoke.url");        assert(StringUtils.isNotEmpty(serviceContainsPath) && StringUtils.isNotEmpty(this.servicesXmlPath)            && StringUtils.isNotEmpty(serviceInvokePath));        JdkDynamicProxy.setServerProviderInvokeUrl(serviceInvokePath);    }}
      
     

import org.springframework.context.annotation.Configuration;import org.springframework.context.annotation.Import;/** * Created by hujunzheng on 2017/7/7. */@Configuration@Import(Registrar.class)public class Config {}

import com.alibaba.fastjson.JSONObject;/** * Created by hujunzheng on 2017/7/7. */public interface ITestService {    JSONObject testService();}

import com.alibaba.fastjson.JSONObject;import com.hjzgg.simulation.api.ITestService;import org.springframework.stereotype.Service;/** * Created by hujunzheng on 2017/7/8. */@Service("testService")public class TestServiceImpl implements ITestService {    @Override    public JSONObject testService() {        JSONObject result = new JSONObject();        result.put("name", "hujunzheng");        result.put("age", 25);        return result;    }}

import com.hjzgg.simulation.api.ITestService;import com.hjzgg.simulation.common.response.SimpleResponse;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RestController;/** * Created by hujunzheng on 2017/7/9. */@RestController@RequestMapping("index")public class ConsumerController {    @Autowired    private ITestService testService;    @RequestMapping("test")    public SimpleResponse test() {        try {            return SimpleResponse.success(testService.testService());        } catch (Exception e) {            e.printStackTrace();            return SimpleResponse.error(e.getMessage());        }    }}