首页 > 经验记录 > 框架

上一篇 Spring Cloud 项目的搭建文章 : 链接

 

再说下我的版本号 , 用的比较新:

 

Spring Boot 2.0.5 RELEASE

Spring Cloud Finchley.SR3

项目管理工具: gradle


进入正题:

从之前的项目构造来看,RPC虽然是实现了,但是调用的链接确是写死在代码中的,比较丑陋。

要是提供服务的地址突然换了,那这边消费者直接雪崩,只能更改代码重新部署。而且无法实现负载均衡,这在一个微服务架构中是很不合理的。

要解决这问题,作为服务消费者,必须要有一个牛逼的服务发现机制。

Spring Cloud 就提供了多种服务发现组件的支持。Eureka、ZooKeeper 等,我这就用 Eureka 了, 在 Spring Cloud 这个生态圈里Eureka是比较流行的。

Eureka是网飞(Netflix)开源的服务发现组件。有Server和Client两部分,按需使用就行,我这就使用他们来构建一个高可用的服务注册中心。

 

我先把之前父模块的的Mybatis、mysql依赖给去了,放到了实际的微服务中(user/movie)。因为Eureka服务不需要这几个依赖,要是加载了mysql依赖会自动连接mysql,不加mysql的配置就会报一堆错误。

 

既然 Eureka 也是个服务,那当然也得在父模块下创建一个Eureka子模块。和其余的模块创建相同,没什么好说的。

给 Eureka 服务注册中心模块加上这个 Eureka Server 依赖

compile(“org.springframework.cloud:spring-cloud-starter-netflix-eureka-server“)

然后在 Eureka 服务的入口 java 文件上加上该注解 @EnableEurekaServer , 这个Application就是完全体了。

 

此时可以在网页里通过 ip:port 来访问页面,可以得知注册中心的状态、多少服务链接到本机。

 

Eureka Server 端写完后,需要注册的服务则需要导入Eureka的Client依赖,就是这个:

compile(“org.springframework.cloud:spring-cloud-starter-netflix-eureka-client“)

然后只要在yml文件中配置好要连接的服务注册中心的地址就完事了,其实此时一个服务注册发现功能已经可以完成了。

但是还不够,需要考虑到若是 Eureka Server 端突然宕掉,那么整个系统就会出问题。

客户端虽然会有相应的缓存(服务注册时会将Server端储存的数据拿到本地缓存),但是在此时若是其他的服务发生变更,靠缓存中的信息去请求就不正确了。

 

所以,想要高可用的一个服务注册中心,则需要搞一个集群。宕掉一个,还有另外的,这样容错率将大大提高。

其实Eureka搞集群非常简单。不过是开启两个实例,A实例注册进B实例,B实例注册进入A实例而已。

只需要使用两种不同的配置即可。(你要是想开五个就是五个不同的配置,看着加就完事了)

像我这样,我这是写在一个yml文件里了,用“—”来隔开,要是配置比较多是可以另起一个文件的,就叫application-xxx.yml。

可以使用 –spring.profiles.active=xxx 来启动不同的服务。

(这里有部分Security的配置,下面就讲)

在IDEA里边,可以使用这种方式来启动不同的实例:

集群也搭完了,启动第一个Eureka Server时可能会出点连接错误,不过不影响启动,这是因为第二个Server还没启动起来,而配置里需要它注册进去导致的,第二个启动起来后就没错误了。

你要是一下子就从网页进去看Eureka的状态,可能会出现红色粗体的:EMERGENCY! EUREKA MAY BE INCORRECTLY CLAIMING INSTANCES ARE UP WHEN THEY’RE NOT. RENEWALS ARE LESSER THAN THRESHOLD AND HENCE THE INSTANCES ARE NOT BEING EXPIRED JUST TO BE SAFE.

这个是Eureka的自我保护机制导致的。Eureka Server和Client之间每隔一段时间会进行一次心跳通信,告诉Server,Client还活着。要是某一段时间Server感觉自己这边少了几个心跳就会出这问题,只要不是真的你服务宕掉了,过一会就好了。

 

配置完毕后,客户端也只需要在配置文件中写两个链接就行,用逗号隔开。其实写一个也可以,因为Eureka集群会自动同步其他Eureka的注册信息。但还是推荐写俩,就是怕某些极端情况发生。

 

此时集群已经搭建完毕。客户端也可以连接得上,但是,这些端口就这样暴露出来也是很不科学的。攻击者可以轻易地得到你的服务信息。

最好的,当然还是加个验证啦!用户名密码这种验证永远不过时哈。

搭建完集群后,用 Spring Security 为 Eureka 增加 Basic 安全认证就很不错了!

只需要在 Eureka Server这边添加 Spring Security 的依赖就够了,Client端不用。

compile(“org.springframework.boot:spring-boot-starter-security“)

 

添加Security的依赖后就会自动开启验证,不用配置。用户名和密码的设定就像上边文件一样,只需要这样就行。

 

配置完用户名和密码后,连接Eureka Server自然就需要用到这些用户名和密码。

本来连接Server的的URL:   http://ip:port/eureka/

现在连接Server的的URL:   http://username:password@ip:port/eureka/

就算是从网页查看状态,也需要输入用户名和密码了哦。

 

Client端最终配置文件如下(反正配置都长得差不多,我这就放其中一个服务的文件就行了):

 

这样,其实应该就完事了,但是,在2.x版本的 Spring Security 中,引入依赖后,自动开启CSRF安全认证。

任何一次服务请求默认都需要CSRF 的token , 而我区区一个小Client,哪里来的这种东西。就是Eureka Server 自注册都会挂掉。

那么还是要让 Security 的CSRF拦截自动忽略掉注册Eureka的链接比较好。

在 Eureka Server 端增加这么一个配置类:

这样子去除 /eureka/  这个连接的 CSRF 效验。就都可以连接上了。

 

OK 整体 Eureka 注册中心都搭建完毕了。并且实现了集群高可用和安全策略,比较完善。

 

服务之间的调用在做一点点微小的改进:

 

通过 DiscoveryClient 这个类,可以获取到对应服务的信息,这里我便是用 movie 服务获取到了user 服务的 url  来进行的调用。

当然,就算是这样,也不是那么的方便,关于feign声明式调用之后也会写篇文章的。

 

我的项目地址: github

阅读全文

Spring Cloud 是在 Spring Boot 基础上构建的,用于快速构建分布式系统的通用模式的工具集

 

别的理论、使用场景、历史之类的也不说了,直接切入主题。

这里,我就来架构一个简单 Spring Cloud 的应用。

 

既然要用,都9102年了,当然要与时俱进,我这里选择的是基于Spring Boot 2.0.x 的Spring Cloud Finchley。

开发工具: IDEA

JDK version: 1.8

具体的框架版本号: Spring Boot 2.0.5 RELEASE、Spring Cloud Finchley.SR3

项目管理工具: gradle  ( 9102年了,maven这xml配置实在是够恶心的了

 

目前只是最原始的初版,使用RestTemplate简单的调用一下别的服务接口。 至于服务注册、发现、跟踪、容错、微服务网关、负载均衡之类的。之后也会慢慢写出文章的。

先把项目给搭起来。之后再要添加新的依赖增加新的功能就就简单许多了。

 

OK,进入正题。

先打开 IDEA 创建一个 Gradle 的Module。我创建的模块名字叫做 sc-demo-microservice

这个是根/父模块, 用于管理一个个的微服务。他可以在 ‘subprojects’ 这个代码块中配置所有子模块通用的配置。

我的build.gradle文件:

 

可以看到我给所有的子模块添加了web、mysql、mybatis、Actuator的依赖。

Actuator这个东西是用于服务监控和管理的,这里不表,具体的可以看这个文章

 

gradle加载完毕后这个父模块就创建好了。gradle会自动给你生成一个src文件夹,删掉就行,也可以不删。反正父模块里边是不会放代码的。

 

然后就是建立子 module 了,子module 的创建是直接在父 module 上边右键 –> new Module 来进行创建的。当然,也是Gradle项目。

建好后将子 module  的 build.gradle文件里的东西全删掉,只留这个:

这个是用来添加该模块独有的依赖的。我这暂时为空。

 

我创建了一个用户微服务、一个电影微服务。里边都有具体的Dao、Service、Entity,这里就不贴了,太占位置。

我这里实现的RPC是通过Spring提供的RestTemplate,链接都是写死的,之后当然会优化。这里只是把项目运转起来。

两边的Controller层:

用户:

 

电影:

 

这样子配好,启动服务时先启动 User 服务,然后启动 Movie 服务,然后通过浏览器输入 Movie 服务的接口获得数据。

最后结果是如愿以偿的得到了数据。而这份数据是 Movie 服务通过 rest 请求 User 服务所得来的。

 

他们的yml文件,因为长得差不多,所以就只贴这一个了

 

 

我的项目地址: github

里边sql语句、配置文件啥的都有。是个完整的项目。

结构如下:

 

下一篇文章是Eureka

阅读全文

WebSocket一次握手就可以使客户端和服务端建立长连接,并进行双向数据传输。

由于其双向传输特性,服务端可主动向客户端发送信息,实时性很高。

而与HTTP协议比起来WebSocket 协议每次数据传输的头信息都较小,节约带宽。

在获取实时数据这方面时,那是比ajax轮询方式高到不知道哪去了。

 

在SpringBoot架构下进行WebSocket服务开发的话,首先还是要导入这个

就算是使用Tomcat 7 的@ServerEndpoint进行 WebSocket开发,也得导。不然在SpringBoot环境下会有bug。

普通java web应用开发WebSocket就不需要了,@ServerEndpoint直接用就行。

maven仓库: spring-boot-starter-websocket

 

这是使用@ServerEndpoint进行的传统WebSocket开发:

由于我是在SpringBoot环境,所以得先写个能扫描@ServerEndpoint的配置,不然在客户端连接的时候会一直连不上。不是在SpringBoot下开发的可以跳过这一环节。

ServerEndpointExporter这个类偏偏还是 spring-boot-starter-websocket 提供的。所以必须要导入这个依赖。

@ServerEndpoint 注解中写上客户端连接的地址。

在类层次上,还得加上 @Component 注解才行。普通java web项目不用加。

这个方式开发的WebSocket服务器,每个连接加入都会为该连接新建一个服务器对象绑定。

这时,一个传统的WebSocket应用就开发完毕了。由于我是在SpringBoot下开发的,所以有一些调整。

启动应用后搞个普通的html页面直接本地打开就可以试验是否能够连接上了。

 

 

不过…我既然都导入了spring-boot-starter-websocket 依赖,自然最好还是用SprinBoot推荐的方法比较好。

这是使用SpringBoot的形式构建WebSocket应用程序:

 

这是核心配置类。实现WebSocketConfigurer接口实现它提供的注册方法。

这个方法就厉害了, 可以配置websocket入口,允许访问的域、注册Handler、定义拦截器等等等等。

@EnableWebSocket用于开启注解接收和发送消息

关于他这个拦截器,是非常重要的,最好还是设置一个。他可以在连接进入到Handler处理时进行一些操作。

比如从session中拿出用户登陆信息作为唯一标识符等等…

我把我的拦截器实现写成内部类了,反正也没多少东西。

这个配置注册的处理器和拦截器,都是只有一个的,无论你多少连接进来,都是用相同的对象处理。

那么就不好用传统的WebSocket开发那样用个集合类容器来存了。

用前置拦截设置进去的某些唯一标识作为key,session作为value用键值对映射类容器来存储连接是比较好的方案。

 

这是我实现的处理器,也是WebSocket开发的核心:

需要实现WebSocketHandler 接口,该接口提供了五个方法。

1、 afterConnectionEstablished():建立新的socket连接后回调的方法。

2、handleMessage():接收客户端发送的Socket。

3、handleTransportError():连接出错时,回调的方法。

4、afterConnectionClosed():连接关闭时,回调的方法。

5、supportsPartialMessages():这个是WebSocketHandler是否处理部分消息,没什么卵用 返回false就完事了。

至此,SpringBoot 与 WebSocket 已经集成完了。客户端仍然使用我上边那个HTML文件就行,访问地址改一下就完事了。

我的这个WebSocket项目整体源码地址:  Github

阅读全文

今天使用Specification 接口创建动态SQL时遇到了个坑。

关于SpringDataJPA如何优雅的定制高效率SQL,即使用Specification 接口创建SQL表示并执行 可以看: 这个

 

主要就是用CriteriaBuilder 创建 locate 语句遇到个问题。以此可以衍生到 CriteriaBuilder 所有用得上Expression入参的方法上。

关于Mysql的locate方法:  LOCATE(substr,str) :返回子串 substr 在字符串 str 中第一次出现的位置。如果子串 substr 在 str 中不存在,返回值为 0: 

CriteriaBuilder 在创建 locate 子句时,第一个参数是 LOCATE(substr,str) 中的 str,第二个才是 substr。完全颠倒了过来。很不符合逻辑。

下面是他的几个创建locate方法:

Expression这玩意,一般是通过Root类的get方法来指定一个表字段的。

根据他提供的方法 我无法做到在一个自定义值中查找table字段是否包含在内,只能判断table字段是否包含我的自定义值。

因为他只有第二个参数接受一个String变量, 即表示传入的String参数是否是第一个参数x的子串(x表示一个表字段,通过root.get()得出)。

而我的需求则为需要在我提供的字符串中寻找一个表字段是否为我提供字符串的子串。

要是想以他提供的方法来实现我的需求,第一个参数是我需要自己设定自定义String值的。而我又无法设定,这就有点恶心了。

 

经过我不懈的查询。终于,什么方案都没查出来。 那没办法了,只能去看一下源码看看有没有什么收获。

我就好奇他这入参String到底经厉了一些什么, 翻了一下,结果还真有。

 

进入到 locate(Expression<String> x, String pattern) 方法的底层实现。

可以看到 他实际上是new 了一个LocateFunction, 传入了String入参pattern

 

然后,看一下所使用到的LocateFunction的构造方法:

嗨,有发现了,他实例化了一个 LiteralExpression 类,传入了 CriteriaBuilder 的一个实现和String类型的pattern参数。

而LiteralExpression 类又实现了Expression接口。

我来一个如法炮制,创建一个LiteralExpression 对象,放入自己想要的参数:  new LiteralExpression<>(cb, title)  。

传的cb对象是Specification 接口的toSpecification 方法提供的CriteriaBuilder 对象。

然后使用这个locate方法:  将我初始化的LiteralExpression作为第一个参数,root.get()获取的Expression作为第二个参数。

然后debug断点调试一下。 emmmm 然后就报错了。

很疑惑,后面又试了一下别的东西,塞不进去,干脆给第一个参数传了个null,神tm就可以了。至于为什么,我也不甚了解。

 

贴上这段转换为sql语句后与我想象吻合的的 Predicate  。

 

阅读全文

其实SpringDataJPA很方便,虽然他是重量级ORM框架,但是在SQL定制上一点都不输于Mybatis。

用@Query注解能使用QueryDsl语法。将nativeQuery属性设置为true就能使用原生SQL手写,也就是Mybatis一样的效果。

实现方式也挺简单的,DAO层接口继承一下CrudRepository就可以进行开发。看国内用的少,应该是因为比较新吧。

这是目前最新的官方文档,里边很多操作可以学习https://docs.spring.io/spring-data/jpa/docs/2.1.3.RELEASE/reference/html/

 

那么SpringDataJPA在代码中如何进行优雅的动态查询呢 ?

如何通过各种条件组装不同的SQL呢 ?

在复杂SQL中为了避免全表扫描要用函数代替某关键字要如何使用呢?

 

使用SpringDataJPA后,DAO层接口一般会继承JpaRepository接口,它可以提供大量供开发者使用的重载查询方法。

比如带Sort的findAll()方法可以按照指定列排序,带Pageable 的findAll()方法可以轻松地实现分页+排序的功能。

但是对于动态查询、复杂SQL来说还是少了。普通的复杂SQL,子查询左右连接啥的,大不了用@Query注解手写。

但是要再加上动态就不一样了。三个参数就会有七种查询方式(1/2/3/12/13/23/123)。总不能写七个方法定制吧。

莫慌,这个时候, JpaSpecificationExecutor 该接口应该就是所需要的了。

 

来看看 JpaSpecificationExecutor  接口自带的方法:

T findOne(Specification<T> spec);
List<T> findAll(Specification<T> spec);
Page<T> findAll(Specification<T> spec, Pageable pageable);
List<T> findAll(Specification<T> spec, Sort sort);
long count(Specification<T> spec);

 

 

最核心的就是 Specification 这个入参。

若想使用 JpaSpecificationExecutor  该接口的方法,则需要创建出实现了 Specification 的对象。然后将其作为查询条件才行。

这是Specification接口:

 

关于 toPredicate() 的几个核心参数 :

  • CriteriaQuery
    接口:该接口定义了顶级查询功能,它包含着查询到各个部分,如:select、from、where、group by、order by 等,CriteriaQuery 对象必须在实体类或嵌入式类型上才起作用
  • CriteriaBuilder
    类:它是 CriteriaQuery 的工厂类,用于构建 JPA 安全查询,可通过 EntityManager.getCriteriaBuilder 而得
  • Root
    接口:该接口继承了 From接口,From 接口继承了 Path 接口,该代表 Criteria 查询的根对象,定义了查询的实体类型,类似于 SQL 中的 FROM 子句,可有多个查询根
  • Predicate
    接口:代表了简单或复杂的查询断言(语句),一个 Predicate 可认为由多个连接词构成

 

这是我在公司写的一个model,可以接收前台用户输入的参数,然后通过一个getSpecification() 方法获取一个Specification实现。

之后该Specification即可作为入参进行 findAll() 的查询。

用来举例应是足够了。

我是用了一个lambda来实现 , 没用过JDK1.8以上版本的可以使用 new Specification 也是一样的。

 

可以看到我的标题匹配使用了mysql的 locate 函数,为的就是避免like关键字的效率低下。

再加上between and获取两个参数的区间,最后还带了一个in,  关键是这几个值都是动态的!若不满足条件则不会进行拼接!

若是该model的值全为默认, 通过这个get方法获取的 Specification 默认就变成一个 WHERE 1=1 的子句。

否则则会根据传入的值返回相应的表达。可以算是比较优雅了。

 

最后,以上边代码的

举个栗子,具体说明一下,这个Predicate是怎么得来的,代表了什么逻辑。

root.get(“title”) 表示为我查询的表(TaoBaoItem)中一个名为 title的列。

cb.locate() 代表使用mysql的 locate函数,它可以找出字符串中一个子串的位置/下标。

 

LOCATE(substr,str) :返回子串 substr 在字符串 str 中第一次出现的位置。如果子串 substr 在 str 中不存在,返回值为 0: 

 

 

cb.gt() 表示 > 符号,gt应该清楚,到处都能用到。第一个参数我填入LOCATE函数,第二个写了个0。

这个Predicate若是以sql的形式表示出来,则是这样子的:

 

这么一举例大概就明白了⑧ , Specification 来定制 sql 确实是好用啊。

 

 

 

 

阅读全文
EA PLAYER &

历史记录 [ 注意:部分数据仅限于当前浏览器 ]清空

      00:00/00:00