我的項(xiàng)目沒(méi)有用到maven? 而是用到了一個(gè)叫g(shù)radle的管理工具
Gradle是一個(gè)基于JVM的構(gòu)建工具倔丈，是一款通用靈活的構(gòu)建工具，支持maven， Ivy倉(cāng)庫(kù)钧惧，支持傳遞性依賴管理，而不需要遠(yuǎn)程倉(cāng)庫(kù)或者是pom.xml和ivy.xml配置文件勾习，基于Groovy浓瞪，build腳本使用Groovy編寫(xiě)。
Motan 的架構(gòu)及模塊設(shè)計(jì)
架構(gòu)設(shè)計(jì)巧婶，分為服務(wù)提供方(RPC Server)乾颁、服務(wù)調(diào)用方(RPC Client)、注冊(cè)中心(Registry)三個(gè)角色艺栈，Server 向 Registry 注冊(cè)聲明所提供的服務(wù)英岭；Client 向 Registry 訂閱指定服務(wù)，與 Registry 返回的服務(wù)列表的 Server 建立連接眼滤，進(jìn)行 RPC 服務(wù)調(diào)用巴席。Client 通過(guò) Registry 感知 Server 的狀態(tài)變更。三者的交互關(guān)系如下圖：
motan-api
可以看做是RPC Server
這里面,就是對(duì)client暴露的接口 ,通俗一點(diǎn),對(duì)外暴露的接口,類似于service
motan-client
這里可以簡(jiǎn)單的看做是調(diào)用端,需要配置config的內(nèi)容如下,這里采用注解的方式配置的
/**
*@Author lccsetsun
*@Description client端配置信息
*/
@Configuration
public class MotanConfiguration {
/**
? ? * @Description: 聲明Annotation用來(lái)指定需要解析的包名
? ? */
? ? @Bean
? ? @ConfigurationProperties(prefix ="motan.annotation")
public AnnotationBean motanAnnotationBean() {
AnnotationBean motanAnnotationBean =new AnnotationBean();
// 添加用到motan注解的類的包名
? ? ? ? return motanAnnotationBean;
}
/**
? ? * @Description: 協(xié)議配置
? ? */
? ? @Bean(name ="motan")
@ConfigurationProperties(prefix ="motan.protocol")
public ProtocolConfigBean protocolConfig() {
ProtocolConfigBean config =new ProtocolConfigBean();
return config;
}
/**
? ? * @Description: 注冊(cè)中心配置
? ? */
? ? @Bean(name ="registry")
@ConfigurationProperties(prefix ="motan.registry")
public RegistryConfigBean registryConfig() {
RegistryConfigBean config =new RegistryConfigBean();
return config;
}
/**
? ? * @Description: 服務(wù)端配置
? ? */
? ? @Bean(name ="basicRefererConfig")
@ConfigurationProperties(prefix ="motan.server")
public BasicRefererConfigBean basicRefererConfigBean() {
BasicRefererConfigBean config =new BasicRefererConfigBean();
return config;
}
}
對(duì)應(yīng)的application.properties 配置文件內(nèi)容為
#\u05e2\ufffd\ufffd\ufffd\ufffd\ufffd\ufffd\ufffd\ufffd\ufffd\ufffd
motan.registry.regProtocol=zookeeper
#motan.registry.address=
motan.registry.address=127.0.0.1:2181
motan.registry.connectTimeout=2000
#\u042d\ufffd\ufffd\ufffd\ufffd\ufffd\ufffd
motan.protocol.name=restful
motan.protocol.endpointFactory=netty
#motan.protocol.minWorkerThread=20 #\ufffd\ufffd\u0421\ufffd\ufffd\ufffd\ufffdpool\ufffd\u07f3\ufffd\ufffd\ufffd
#motan.protocol.maxWorkerThread=50 #\ufffd\ufffd\ufffd\ufffd\ufffdpool\ufffd\u07f3\ufffd\ufffd\ufffd
motan.protocol.maxContentLength=1048576
motan.protocol.isDefault=true
#\u05b8\ufffd\ufffd\ufffd\ufffd\u04aa\ufffd\ufffd\ufffd\ufffd\ufffd\u0130\ufffd\ufffd\ufffd
motan.annotation.package=cn.thunderwind.uc.user? ?
#\ufffd\ufffd\ufffd\ufffd\ufffd\ufffd\ufffd\ufffd\ufffd
motan.server.protocol=motan
motan.server.registry=registry
motan.server.throwException=true
# mongodb
spring.data.mongodb.uri=mongodb://192.168.1.203:27017/log_db
# \ufffd\u02ff\ufffd
server.port=9087
motan-server
server則是具體操作,你要操作什么邏輯,全在這里操作,操作mapper? 調(diào)用方法等等
驅(qū)動(dòng)配置如下
/**
*@Author lccsetsun
*@Date 2018/2/1
*@Description? motan配置信息
*/
@Configuration
public class MotanConfiguration {
/**
? ? * @Description: 聲明Annotation用來(lái)指定需要解析的包名
? ? */
? ? @Bean
? ? @ConfigurationProperties(prefix ="motan.annotation")
public AnnotationBean motanAnnotationBean() {
AnnotationBean motanAnnotationBean =new AnnotationBean();
return motanAnnotationBean;
}
/**
? ? * @Description: 協(xié)議配置
? ? */
? ? @Bean(name ="motan")
@ConfigurationProperties(prefix ="motan.protocol")
public ProtocolConfigBean protocolConfig1() {
ProtocolConfigBean config =new ProtocolConfigBean();
return config;
}
/**
? ? * @Description: 注冊(cè)中心配置
? ? */
? ? @Bean(name ="registry")
@ConfigurationProperties(prefix ="motan.registry")
public RegistryConfigBean registryConfig() {
RegistryConfigBean config =new RegistryConfigBean();
return config;
}
/**
? ? * @Description: 服務(wù)端配置
? ? */
? ? @Bean
? ? @ConfigurationProperties(prefix ="motan.server")
public BasicServiceConfigBean baseServiceConfig() {
BasicServiceConfigBean config =new BasicServiceConfigBean();
return config;
}
}
對(duì)應(yīng)的properties配置文件
# \ufffd\u02ff\ufffd
server.port=9996
#AOP
spring.aop.proxy-target-class=true
spring.thymeleaf.cache=false
# \ufffd\ufffd\ufffd\u077f\ufffd
spring.datasource.url=jdbc:mysql://name?characterEncoding=utf8&useSSL=true
spring.datasource.username=name
spring.datasource.password=1123
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
# REDIS (RedisProperties)
spring.redis.database=1
spring.redis.host=192.168.1.203
spring.redis.port=6379
spring.redis.password=
spring.redis.pool.max-active=8
spring.redis.pool.max-wait=-1
spring.redis.pool.max-idle=8
spring.redis.pool.min-idle=0
spring.redis.timeout=0
# \ufffd\ufffd\u05be\ufffd\ufffd\ufffd\ufffd\ufffd\u026b
spring.output.ansi.enabled=DETECT
# mongodb
spring.data.mongodb.uri=mongodb://192.168.1.203:27017/log_db
# mybatis
mybatis.config-locations=classpath:myBatis-config.xml
mybatis.mapper-locations=classpath:mapper/*.xml
## motan
motan.registry.regProtocol=zookeeper
motan.registry.address=127.0.0.1:2181
motan.registry.connectTimeout=2000
##\u042d\ufffd\ufffd\ufffd\ufffd\ufffd\ufffd
motan.protocol.name=restful
motan.protocol.endpointFactory=netty
#motan.protocol.minWorkerThread=20 #\ufffd\ufffd\u0421\ufffd\ufffd\ufffd\ufffdpool\ufffd\u07f3\ufffd\ufffd\ufffd
#motan.protocol.maxWorkerThread=50 #\ufffd\ufffd\ufffd\ufffd\ufffdpool\ufffd\u07f3\ufffd\ufffd\ufffd
motan.protocol.maxContentLength=1048576
motan.protocol.isDefault=true
#motan.protocol.filter=statistic
##\u05b8\ufffd\ufffd\ufffd\ufffd\u04aa\ufffd\ufffd\ufffd\ufffd\ufffd\u0130\ufffd\ufffd\ufffd
motan.annotation.package=cn.thunderwind
##\ufffd\ufffd\ufffd\ufffd\ufffd\ufffd\ufffd\ufffd\ufffd
motan.server.export=motan:8003
motan.server.registry=registry
motan日志記錄以及攔截請(qǐng)求
import java.util.HashMap;
import java.util.Map;
/**
* describe:
* MotanService 日志記錄
* @author hetong
* @date 2018/01/30
**/
@SpiMeta(name ="motanLogFilter")
@Activation(key = {MotanConstants.NODE_TYPE_SERVICE}, sequence =30)
public class MotanLogFilterimplements Filter {
private final static GtLoggerlogger = GtLoggerFactory.getLogger(MotanLogFilter.class);
@Override
? ? public Response filter(Caller caller, Request request) {
Long start = System.currentTimeMillis();
Map info =new HashMap<>(7);
info.put("content","MotanService層日志");
info.put("loggerName", request.getInterfaceName());
info.put("method", request.getMethodName());
info.put("attachments", request.getAttachments());
info.put("requestId", request.getRequestId());
Map args =null;
if ( request.getArguments() !=null && request.getArguments().length >0 ) {
args =new HashMap<>(request.getArguments().length);
for (Object arg : request.getArguments()) {
if (arg !=null) {
args.put(arg.getClass().getName(), arg.toString());
}
}
}
info.put("remoteAddress", caller.getUrl().getHost());
info.put("arguments", args);
Response response = caller.call(request);
info.put("takeTime", System.currentTimeMillis() - start);
logger.operate(Operates.desc("MotanService"), JSON.toJSON(info).toString());
Exception exception = response.getException();
if (response ==null || exception !=null) {
info.put("exception", exception.getMessage());
}
logger.operate(Operates.desc("Motan Service"), JSON.toJSONString(info));
return response;
}
}
統(tǒng)一異常處理
@SpiMeta(name = "motanExceptionFilter") @Activation(key = {MotanConstants.NODE_TYPE_SERVICE}, sequence = 40) public class MotanExceptionFilter implements Filter { private final static GtLogger logger = GtLoggerFactory.getLogger(MotanExceptionFilter.class); @Override public Response filter(Caller caller, Request request) { Response response = null; boolean isThrowable = false; DefaultResponse e_resp = null; try { response = caller.call(request); Exception exception = response.getException(); if (response == null || exception != null) { isThrowable = true; e_resp = transExceptionRespWithResp(response, exception.getCause()); } } catch (Exception e) { isThrowable = true; e_resp = transExceptionRespWithReq(request, e.getCause()); } return isThrowable ? e_resp : response; } private DefaultResponse transExceptionRespWithResp(Response response, Throwable exception) { logger.error("MotanService 返回異常", exception); DefaultResponse dResp = new DefaultResponse(); dResp.setAttachments(response.getAttachments()); dResp.setProcessTime(response.getProcessTime()); dResp.setRpcProtocolVersion(response.getRpcProtocolVersion()); dResp.setRequestId(response.getRequestId()); dResp.setValue(new ResponseEntity.Builder().setData(exception) .setMessage("返回異常! error:" + exception.getMessage()) .setStatus(-1) .build()); return dResp; } private DefaultResponse transExceptionRespWithReq(Request response, Throwable exception) { logger.error("MotanService 返回異常", exception); DefaultResponse dResp = new DefaultResponse(); dResp.setAttachments(response.getAttachments()); dResp.setRpcProtocolVersion(response.getRpcProtocolVersion()); dResp.setRequestId(response.getRequestId()); dResp.setValue(new ResponseEntity.Builder().setData(exception) .setMessage("返回異常! error:" + exception.getMessage()) .setStatus(-1) .build()); return dResp; } }
