Java后端支付大杂烩之core.dao，service，web(重点是接口的设计)（二）
PayMap
PayMap是一个使用Java语言集成三方支付的小Demo，现已集成支付宝（国内、国际、移动端、PC端）、微信、银联（ACP、UPOP）、光大（网关、网页）、邮政支付，采用的技术栈为：SpringMVC+Spring+MyBatis+Shiro+RabbitMQ+Redis。java
特性
- 支持前面提到的各类**支付
- 支付请求调用支持HTTP和异步MQ
- 控制层统一异常处理
- LogBack日志记录
- Redis缓存机制
- Shiro安全机制
- MyBatis代码自动生成
- HTTP请求日志记录
- RESTful APIs
说明
- 一、本文项目来自Martin404,本身只是临摹大佬的项目。
- 二、重要的是学习过程，而不是结果。但，结果一样重要，加油。gogogo。
- 三、框架搭建就略过了。配置文件太多。遇到的时候贴出来。也收藏起来，留着备用。
- 四、Gist、Insight.io for GitHub必备吧，划词翻译不懂的单词划一划。
- 五、在IDEA中我会注重代码规范，可是这里为了节约地方，能省的就省略了。还请谅解。
- 六、代码提交到这里了GitHub。根据提交记录找本身想要的类库。
- 七、重要的在后面，一切都只只是刚刚开始(但愿不要被屏蔽)！！gogogo
二、核心包～common.dao,service,web,mq.
(1)、咱们先从dao开始吧，这里也能够是web。熟悉的来了，IBaseMapper<T> 仍是定义基础接口，但与中不一样的是这个用泛型<T>修饰，为何呢？先看一张图。git
<img src="https://user-gold-cdn.xitu.io...;h=570&f=jpeg&s=28410" width = "300" height = "200"/>github
图片+代码能够说明一切问题。反射+泛型。很重。要是还不懂，再用文字描述web
- 一、泛型类，是在实例化类的时候指明泛型的具体类型；支持建立能够按类型进行参数化的类
- 二、泛型方法，是在调用方法的时候指明具体的类型。
public List<T> findAll() {} - 三、泛型接口，JDK，Spring中大量运用泛型。
总结来讲泛型能够提升Java程序的类型安全，全部的类型转换都是自动和隐式的。为优化，性能带来收益。redis
IBaseDao接口：spring
/**
* 持久层通用接口
*/
public interface IBaseDao<T> {
void save(T entity);
void delete(T entity);
void update(T entity);
T findById(Serializable id);
List<T> findAll();
}
BaseDaoImpl<T>实现类：sql
/**
* 持久层通用实现
*/
public class BaseDaoImpl<T> extends HibernateDaoSupport implements IBaseDao<T> {
//表明的是某个实体的类型
private Class<T> entityClass;
@Resource//根据类型注入spring工厂中的会话工厂对象sessionFactory
public void setMySessionFactory(SessionFactory sessionFactory){
super.setSessionFactory(sessionFactory);
}
//在父类（BaseDaoImpl）的构造方法中动态得到entityClass
public BaseDaoImpl() {
ParameterizedType superclass = (ParameterizedType) this.getClass().getGenericSuperclass();
//得到父类上声明的泛型数组
Type[] actualTypeArguments = superclass.getActualTypeArguments();
entityClass = (Class<T>) actualTypeArguments[0];
}
public void save(T entity) {
this.getHibernateTemplate().save(entity);
}
public T findById(Serializable id) {
return this.getHibernateTemplate().get(entityClass, id);
}
public List<T> findAll() {
String hql = "FROM " + entityClass.getSimpleName();
return (List<T>) this.getHibernateTemplate().find(hql);
}
}
(2)、接下来，再看本项目中定义IBaseMapper<T>chrome
- @SelectProvider注解用于生成查询用的sql语句，有别于@Select注解，@SelectProvide指定一个Class及其方法，而且经过调用Class上的这个方法来得到sql语句。
- @ResultMap注解用于从查询结果集RecordSet中取数据而后拼装实体bean。
- @SelectProvide方法，若是参数使用了@Param注解，那么参数在Map中以@Param的值为key
在这里使用了注解的形式，可是也能够在XMl方法配置。json
public interface IBaseMapper<T> {
@SelectProvider(type = MapperProvider.class, method = "dynamicSQL")
T selectOne(T record);
@SelectProvider(type = MapperProvider.class, method = "dynamicSQL")
T selectByPrimaryKey(Object key);
@InsertProvider(type = MapperProvider.class, method = "dynamicSQL")
int insert(T record);
...........................忽略了几个.......................
@DeleteProvider(type = MapperProvider.class, method = "dynamicSQL")
int delete(T record);
@DeleteProvider(type = MapperProvider.class, method = "dynamicSQL")
int deleteByPrimaryKey(Object key);
@DeleteProvider(type = MapperProvider.class, method = "dynamicSQL")
int deleteByExample(Object example);
@UpdateProvider(type = MapperProvider.class, method = "dynamicSQL")
int updateByExample(@Param("record") T record, @Param("example") Object example);
List<T> getAllByPage(RowBounds rowBounds); //这个是用于分页的。
}
(3)、中间插一个RabbitMQ MSG序列化JSON转换器，主要做用是客户端和服务端须要传输Json格式的数据包，因此须要进行转换。这个工具包也是必备的之一。友情提示，安装MQ时，必定要以系统管理员运行CMD。数组
RabbitMQ已经实现了Jackson的消息转换（Jackson2JsonMessageConverter），因为考虑到效率，以下使用Gson实现消息转换。
以下消息的转换类的接口MessageConverter，Jackson2JsonMessageConverter的父类AbstractJsonMessageConverter针对json转换的基类。
咱们实现Gson2JsonMessageConverter转换类也继承AbstractJsonMessageConverter。
为了节约地方，代码放Gist了，须要的时候直接去找。
/**
* MQ MSG序列化JSON转换器
*/
public class Gson2JsonMessageConverter extends AbstractJsonMessageConverter {
private static Logger logger = LoggerFactory.getLogger(Gson2JsonMessageConverter.class);
private static ClassMapper classMapper = new DefaultClassMapper();
private static Gson gson = new Gson();
@Override
protected Message createMessage(Object object, MessageProperties messageProperties) {
byte[] bytes = null;
try {
String jsonString = gson.toJson(object);
jsonString.getBytes(getDefaultCharset());
}
catch (IOException e) {
new MessageConversionException("Failed to convert Mesage context",e);
}
messageProperties.setContentType(MessageProperties.CONTENT_TYPE_JSON);
messageProperties.setContentEncoding(getDefaultCharset());
if (bytes != null) {
messageProperties.setContentLength(bytes.length);
}
classMapper.fromClass(object.getClass(),messageProperties);
return new Message(bytes,messageProperties);
}
@Override
public ClassMapper getClassMapper() {
return new DefaultClassMapper();
}
}
(4)、接下来就是定义基础IBaseService以及实现类
public interface IBaseService<T> {
/**
* 根据主键查询指定实体
*/
T getId(Object id) ;
List<T> getByEntiry(T entity);
PageInfo<T> getByPage(RowBounds rowBounds);
int save(T entity);
int update(T entity);
int delete(Object id);
int saveSelective(T entity) throws DBException;
int updateSelective(T entity);
}
IBaseService:所有代码在这Gist
/**
* Created by guo on 3/2/2018.
*/
public abstract class BaseService<T> implements IBaseService<T> {
private static Logger logger = LoggerFactory.getLogger(BaseService.class);
@Resource
protected RabbitTemplate amqpTemplate;
@Autowired
protected RedisTemplate redisTemplate;
public abstract IBaseMapper<T> getBaseMapper();
/**
* 根据主键查询指定实体
* @param id
* @return
*/
@Override
public T getId(Object id) {
return this.getBaseMapper().selectByPrimaryKey(id);
}
/**
* 获取分页数据
*/
@Override
public PageInfo<T> getByPage(RowBounds rowBounds) {
List<T> list = this.getBaseMapper().getAllByPage(rowBounds);
return new PageInfo<T>(list);
}
/**
* 保存对象，保存全部属性
*/
@Override
public int save(T entity) {
return this.getBaseMapper().insert(entity);
}
/**
* 删除指定数据
*/
@Override
public int delete(Object id) {
return this.getBaseMapper().deleteByPrimaryKey(id);
}
/**
* 更新对象，值更新对象中不为Null的属性，主键不能为NULL
*/
@Override
public int updateSelective(T entity) {
return this.getBaseMapper().updateByPrimaryKeySelective(entity);
}
}
(5)、接下来就是web包中的内容，涉及监听器和过滤器。
/**
* 系统初始化监听器,在系统启动时运行,进行一些初始化工做
*/
public class InitListener implements javax.servlet.ServletContextListener {
private static Logger logger = LoggerFactory.getLogger(InitListener.class);
public static ApplicationContext context;
public void contextDestroyed(ServletContextEvent arg0) {
}
public void contextInitialized(ServletContextEvent servletContextEvent) {
context = WebApplicationContextUtils.getRequiredWebApplicationContext(servletContextEvent.getServletContext());
//加载银联upop配置文件
SDKConfig.getConfig().loadPropertiesFromSrc();
String proPath = servletContextEvent.getServletContext().getRealPath("/");
SDKConfig config = SDKConfig.getConfig();
config.setSignCertDir(proPath + config.getSignCertDir());
config.setSignCertPath(proPath + config.getSignCertPath());
config.setValidateCertDir(proPath + config.getValidateCertDir());
//缓存初始化忽略
}
}
过滤器：
咱们先看关于日志的，真心看不懂，后面有一大堆。代码地址
/**
* request response log记录过滤器
*/
public class LoggingFilter extends OncePerRequestFilter {
protected static final Logger logger = LoggerFactory.getLogger(LoggingFilter.class);
private static final String REQUEST_PREFIX = "Request: ";
private static final String RESPONSE_PREFIX = "Response: ";
private AtomicLong id = new AtomicLong(1);
@Override
protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, final FilterChain filterChain) throws ServletException, IOException {
if (logger.isDebugEnabled()) {
long requestId = id.incrementAndGet();
request = new RequestWrapper(requestId, request);
}
try {
filterChain.doFilter(request, response);
} finally {
if (logger.isDebugEnabled()) {
logRequest(request);
}
}
}
//...
}
还有一个请求包装类，和响应类。。代码地址
public class RequestWrapper extends HttpServletRequestWrapper {
private final ByteArrayOutputStream bos = new ByteArrayOutputStream();
private long id;
public RequestWrapper(Long requestId, HttpServletRequest request) {
super(request);
this.id = requestId;
}
@Override
public ServletInputStream getInputStream() throws IOException {
return new ServletInputStream() {
private TeeInputStream tee = new TeeInputStream(RequestWrapper.super.getInputStream(), bos);
@Override
public int read() throws IOException {
return tee.read();
}
};
}
public byte[] toByteArray() {
return bos.toByteArray();
}
}
---------------------------------------------------------------------------------
public class ResponseWrapper extends HttpServletResponseWrapper {
private final ByteArrayOutputStream bos = new ByteArrayOutputStream();
private PrintWriter writer = new PrintWriter(bos);
private long id;
public ResponseWrapper(Long requestId, HttpServletResponse response) {
super(response);
this.id = requestId;
}
@Override
public ServletOutputStream getOutputStream() throws IOException {
return new ServletOutputStream() {
private TeeOutputStream tee = new TeeOutputStream(ResponseWrapper.super.getOutputStream(), bos);
@Override
public void write(int b) throws IOException {
tee.write(b);
}
};
}
@Override
public PrintWriter getWriter() throws IOException {
return new TeePrintWriter(super.getWriter(), writer);
}
public byte[] toByteArray() {
return bos.toByteArray();
}
}
这一块只是得补补，用到的时候再看，还有一个TeePrintWriter
核心包的东东算是完了，重点是在IBaseMapper、IBaseService的设计。这里用到了泛型，还有Mybatis3.X新特性，基于注解的。其实彻底能够用XML配置文件。
gogogo 正式进入业务逻辑部分。
相关文章
- 1. Java后端支付大杂烩之sps.controller(支付请求入口，配置文件)（五）
- 2. 前端大杂烩之JS（二）
- 3. 前端大杂烩
- 4. Nancy之大杂烩
- 5. java web 支付宝的接口问题
- 6. HTML+CSS知识点大杂烩（二）
- 7. 支付宝支付之APP支付接口 服务器端
- 8. Java后端支付大杂烩之core.common、utils(异常，ID，日期，字符串等工具类)（一）
- 9. 前端素材大杂烩
- 10. 前端问题大杂烩
- 更多相关文章...
- • Web 创建设计 - 网站建设指南
- • Eclipse 创建 Java 接口 - Eclipse 教程
- • 互联网组织的未来：剖析GitHub员工的任性之源
- • ☆基于Java Instrument的Agent实现
相关标签/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
最新文章
欢迎关注本站公众号,获取更多信息
