上一篇 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

阅读全文

看下这样一段代码:

我在一个方法中建立了个死循环,循环的判断条件为一个boolean类型的成员变量。

然后在main线程中,创建了一个新的名为 “t1” 的线程,去执行这个方法。

等待一秒后,mian线程自身,将该成员变量的值改为false,试图使其不满足条件从而循环终止。

按照正常的逻辑来说,按照脑海中预演的情况来说,应该是没问题的。

可是执行后却没有得到想要的结果,控制台输出 “start” 后再无反应,程序一直没有终止,即 死循环没有退出。

 

想要让程序正确执行的话,将定义语句 boolean flag = true; 改为 volatile boolean flag = true;  程序就可以正确执行,这是为什么呢?

 

这里要涉及一点 java 内存模型,JMM。

JMM 里头,他有分配一块内存,叫主内存。类比于操作系统中的主存,主要存放线程间的共享数据(除去方法参数、局部变量)。

然后,每个线程在执行的过程当中,都有一个WorkingMemory,是主内存中部分数据的副本,只能该线程访问,类比于硬件的高速缓存。线程对数据的访问通常只能在workingMemory中进行,不能直接与主存交互。

比如cpu运行多个不同的线程的话,每个线程都有一个WorkingMemory,cup就是将主内存里边的数据读过来读到WorkingMemory里,然后再进行修改,比如+1+1+1+1,修改完后,再给他写回内存去。

 

我上边写的代码,这几个线程是怎么执行的呢?

在我的代码中,flag 是存在于堆内存中的 v 对象中。

当线程 t1 开始跑后,它首先会从主内存中把这个 flag 变量给它 copy 到自己的工作内存里边,然后开始运行。在cpu处理的过程之中,由于这cpu处理这个线程的部分他非常的忙,一直在while循环嘛,就不再去读主内存里边的数据了,一直在读自己的缓冲区(线程的工作内存)。

main 线程,改flag的参数,也是把 flag 参数 true 给读到自己的工作内存里边,然后进行修改,修改完事后,发现自己工作内存中的数据和主存中不一致,于是将自己工作内存中的数据给他刷新到主存中去。

这个时候就有问题了。第一个线程没有在主存里重新读啊?所以,这时候第一个线程就结束不了。

 

 

volatile 关键字功能及作用:

简单的来说,volatile 关键字,主要功能是使一个变量在多个线程间可见。

volatile关键字修饰的变量一旦在主存中被改变时,就会通知别的使用到该变量的线程:你们的缓冲区中的内容过期了,需要再重新刷新一下。

以上面那个代码例子来说 ,这样定义语句 volatile boolean flag = true;

当 main 线程修改主内存中 flag 的值时。这个时候, t1 线程,就会去重新读一遍主存,刷新自己的缓冲区(工作空间)。此时 t1 线程中的 flag 刷新为 false ,故循环停止。程序运行完毕。

 

虽然 volatile 用起来比较简单,但是该关键字背后代表的逻辑还是很深的。

 

 

还有个点要注意:

volatile并不能保证多个线程共同修改某一变量时所带来的不一致问题,也就是说 volatile 不能代替 synchronized。

当然, volatile 的效率高 synchronized 很多倍。但是该上锁的时候也只能上锁。

synchronized 是 既有可见性,又保证原子性。而 volatile 只保证可见性。synchronized的实现也是比 volatile 更重的。

 

 

关于 synchronized  本来也有一篇文章要写的。想想还是算了,本来想写点加锁释放锁的原理、可重入性质和可见性和原理啥的。

不过我过了归纳的那一段时间了,现在想归纳总结一通怪麻烦的。反正这些知识脑子里都有,就不记录了。

 

阅读全文

医生说恢复得很好,但还是让我别上班,要我继续躺一个月再去上班,休息还不够。

不过我个人倒是早就做好各种准备了,这个结果也在意料之中。毕竟伤筋动骨一百天,何况我还是伤的腰椎。坚决按照医生医嘱,继续躺吧。

看了下复查x片,我也觉得也还可以,虽说是永久性损伤,但是还是尽量能恢复多少恢复多少。

我今天上午折腾一上午,挂号啊、拍片啊。或走或站或坐,总共四个小时多把。腰不疼,倒是酸的不行,我用肉体体会到了现在这个状态确实是不能久坐的。

这俩月各种资料也了解过,过个半年一年的就基本和正常人一样了。除了不能做剧烈运动、对抗性运动。

 

 

我心态还是很不错,反正吃的也好睡得也香,躺着没啥不舒服,现在上厕所之类的都是自己下床解决了,偶尔起来走两步,没什么压力。

工作的话随缘吧,给了我俩个月假,已经很感激了,要是接受不了我继续休息第三个月,也可以好聚好散。找个工作以我个人水平还是比较简单,逆医嘱上班是不存在的(能继续给假是最好的啦,我房子还租着呢)。

 

 

这两个月,虽说躺着不方便,躺久了看手机眼疼、趴久了胸闷、趴着用手撑手酸,现在手部肘关节估摸着有些劳损。

但我多少还是在成长,编码少年天天绝赞进化中!

《Effectve Java》看到了一百五十多页,已经超过一半。

慕课网的【Java高并发之魂:synchronized深度解析】看完了,对synchronized可以说理解的很通透了,不过过了些时间,记忆有点模糊,我之后找个时间再看一下总结篇,写篇日志记录。

一个外国讲计算机科学的课程:【Crash Course Computer Science】 也看了20集,看了一半了,总共40集。真的受益匪浅,从早期计算机历史开始讲起、到晶体管搭逻辑门、到寄存器/内存、CPU的设计都讲的很好,从编程的最初始形态(打孔纸)慢慢到现在的汇编、编译器解释器、高级语言。操作系统如何做内存分配、虚拟内存,数据如何存在储存介质中、等等等等。 让我涨了不少姿势。

 

大概就这样了,这也不过是我一生中稍微不一样的两个月而已。并不会影响到我什么。虽说前一个半月过得很煎熬,躺着浑身难受,但是到后面还是慢慢的习惯了。

有句话不是说:没有打倒我的,最终将成为我前进的动力?

不过我不需要什么东西来作为我前进的动力,毕竟我始终在前进。疾病终将成为过眼云烟,时间推到一年后、几年后,现在这几个月的经历,痛苦也好、到后面的平静也好 也不过是在记忆的一角,提醒我有过这么一段时间,而已。

 

 

 

阅读全文

现在是2019年3月04日早上5点15分左右。

勉强用手机敲下这篇博客。

 

一晚没睡。一点都没睡着。昨天经历了人生第一次住院,第一次坐轮椅。想来也是一段经历了。。。过几天还要去做核磁共振,这回得上担架上救护车了,这也太cooooool了⑧,这场面我只在电视里看过啊。

 

说起来也是自己作死,这尼玛我就是一个无聊去我安的引体向上杠子那里甩了两下,神tm掉下来了,想想也是,都安了好几个月了,也没去检查一下松没松。这下好了,L1腰椎压缩性骨折,看了一下没到1/3,算是二级轻伤。

 

摔的那一瞬间,无法形容,脑袋一片空白。只会在地上蠕动和抽搐+惨叫,什么都无法思考了,现在回忆一下,那是叫的真惨。当时就感觉要凉,这tm可是摔了腰椎啊,我以后要残废?忍着剧痛从地上爬到床上,现在还能想起我当时出了一身冷汗,全身都湿了。不过还好,我心态一向很好,毕竟我还能爬动,那么看来没伤到神经。(打这段字期间被抽了个血,hh)

 

后来我自己躺了一个小时,然后勉强站起来走动打了个滴滴去最近的医院赶紧看一下,这之间的酸爽就不是一言两语能道清的了,然后拍ct,发现骨折,打电话告知家人,赶紧开车来医院接我去省里最好的骨科医院住院。然后还打了两瓶点滴贴了个膏药。从三点折腾到十点,可算是正式住院躺下了。

 

hh,之后吃喝拉撒都要在床上度过了。 这尼玛。还好工作算是没丢,本来都想着这下肯定凉凉,这两个月躺着看来得背俩月面试题了。还好没被飞,算是不错吧。

 

看看能不能做到在床上学习吧,代码是敲不了了,周六我还tm看了一下午的synchronized关键字分析与底层实现,这俩月看看能不能多看一些非实战性的,偏知识讲解的视频吧。哎,也不知道好不好做笔记。

人的一生啊,固然得考虑自我奋斗,但是也要考虑到历史进程啊。天让我躺,我能咋办。(归根揭底还是自己作死)

 

 

 

 

 

阅读全文
EA PLAYER &

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

      00:00/00:00