微服务

Posted 2020-09-08 Leo_wlCnBlogs

微服务

前言

微服务，顾名思义就是微小的单一的服务程序，单一流程，单一发布，开发和部署都可独立；

这是我的理解；

但基于web的服务，不管是webservice还是webapi等类似的服务都需要基于iis或者tomcat，

本文介绍重点绕过iis或tomc部署基于http服务明文程序；

所谓明文程序就是源码发布；当然你也可以不必是源码发布，这个可以个人需求；

序言

请不要问我为什么不直接使用web现成的架构，进行开发部署，

第一：我的项目有这样的需求；原本就是一个服务程序，提供socket tcp协议数据服务；并且需要提供socket http协议服务；

第二：梳理自己的知识；

第三：对微服务和webapi概念进行强化和模拟实现；

正文开始

在阅读这篇文字之前建议优先查看之前文章，比如线程，脚本，socket 服务等；

本文先从java版本开始讲解；稍后依然会写上C#，但是代码机制都是一样的；本程序习惯作风，java和C#双版本共存；

 本人代码风格习惯，：

项目主包下面包含功能块实现；功能块里面包含单例管理器，如果需要有脚本接口处理iscript里面包含接口的处理形式

我们优先创建文件IWebApiScript

 View Code

 

 创建WebApiManager

 1 package net.sz.game.test.webapi;
 2 
 3 import java.util.ArrayList;
 4 import net.sz.game.engine.nio.nettys.NettyPool;
 5 import net.sz.game.engine.nio.nettys.http.NettyHttpServer;
 6 import net.sz.game.engine.nio.nettys.http.NioHttpRequest;
 7 import net.sz.game.engine.nio.nettys.http.handler.IHttpHandler;
 8 import net.sz.game.engine.scripts.IBaseScript;
 9 import net.sz.game.engine.scripts.manager.ScriptManager;
10 import net.sz.game.engine.szlog.SzLogger;
11 import net.sz.game.test.webapi.iscript.IWebApiScript;
12 
13 /**
14  *
15  * <br>
16  * author 失足程序员<br>
17  * blog http://www.cnblogs.com/ty408/<br>
18  * mail [e-mail]<br>
19  * phone [phone]<br>
20  */
21 public class WebApiManager {
22 
23     private static SzLogger log = SzLogger.getLogger();
24     private static final WebApiManager IN_ME = new WebApiManager();
25 
26     public static WebApiManager getInstance() {
27         return IN_ME;
28     }
29 
30     public void init() {
31         /*获取http绑定*/
32         NettyHttpServer addBindHttpServer = NettyPool.getInstance().addBindHttpServer("127.0.0.1", 9527);
33 
34         /*添加黑名单 禁止访问名单*/
35         //addBindHttpServer.addBlackIP("");
36         /*添加白名单 必须包含的访问*/
37         //addBindHttpServer.addWhiteIP("");
38         addBindHttpServer.addHttpBind(new IHttpHandler() {/*使用匿名对象*/
39 
40             @Override
41             public void run(String url, NioHttpRequest request) {
42                 /*每次都是获取最新集合*/
43                 ArrayList<IBaseScript> evts = ScriptManager.getInstance().getBaseScriptEntry().getEvts(IWebApiScript.class.getName());
44                 if (evts != null && !evts.isEmpty()) {
45                     for (int i = 0; i < evts.size(); i++) {
46                         IWebApiScript iWebApiScript = (IWebApiScript) evts.get(i);
47                         /*查找需要处理的明文脚本 webapi 路由*/
48                         if (iWebApiScript.getRoute().equalsIgnoreCase(url)) {
49                             /*返回值也行有其他用途*/
50                             boolean action = iWebApiScript.action(url, request);
51                             /*跳出循环*/
52                             break;
53                         }
54                     }
55                 }
56                 /*回复客户端请求*/
57                 request.respons();
58             }
59         }/*处理程序*/, 10/*线程量提高并发处理*/, "*"/*监听状态*/);
60         /*socket 使用*/
61         addBindHttpServer.start(4);
62     }
63 }

 

当前我们并没有实现路由注册，

我们看看效果将会是怎么样的；

 

当我们在浏览器输入的时候，不会有任何回复产生；

接下来我们试试明文脚本的路由自动注册效果来回复请求；

我们新建项目，保持项目路径一直；

net.sz.game.test.scripts

我们在webapi的脚本目录下创建index路由监听

 

 1 package net.sz.game.test.scripts.webapi;
 2 
 3 import net.sz.game.engine.nio.nettys.http.NioHttpRequest;
 4 import net.sz.game.engine.szlog.SzLogger;
 5 import net.sz.game.test.webapi.iscript.IWebApiScript;
 6 
 7 /**
 8  *
 9  * <br>
10  * author 失足程序员<br>
11  * blog http://www.cnblogs.com/ty408/<br>
12  * mail [e-mail]<br>
13  * phone [phone]<br>
14  */
15 public class IndexScript implements IWebApiScript {
16 
17     private static SzLogger log = SzLogger.getLogger();
18 
19     @Override
20     public String getRoute() {
21         return "index";
22     }
23 
24     @Override
25     public boolean action(String url, NioHttpRequest request) {
26         /*添加输出内容，html数据，json数据，txt数据，xml数据，自己定义就好*/
27         request.addContent("我是明文webapi自动注册路由");
28         return true;
29     }
30 
31 }

 

 

 

实现路由自动注册我们需要在启动main函数加入脚本初始化函数调用 

 1 package net.sz.game.test.main;
 2 
 3 import java.util.ArrayList;
 4 import net.sz.game.engine.scripts.manager.ScriptManager;
 5 import net.sz.game.engine.szlog.SzLogger;
 6 import net.sz.game.test.webapi.WebApiManager;
 7 
 8 /**
 9  *
10  * <br>
11  * author 失足程序员<br>
12  * mail [e-mail]<br>
13  * phone [phone]<br>
14  */
15 public class Test_App_Manager {
16 
17     private static SzLogger log = SzLogger.getLogger();
18 
19     public static void main(String[] args) {
20 
21         /*加载所有脚本文件，默认加载项目路径 -scripts 文件下面所有问题*/
22         ArrayList<String> loadScripts = ScriptManager.getInstance().reload();
23         String join = String.join(",", loadScripts);
24         log.error(join);
25         /*初始化监听*/
26         WebApiManager.getInstance().init();
27     }
28 }

 

 启动程序测试

 启动程序以后我们看到首先删除了程序项目下面之前的脚本临时文件，然后重新加载最新脚本文件；成功加载脚本：net.sz.game.test.scripts.webapi.IndexScript, net.sz.game.test.webapi.iscript.IWebApiScript

在浏览器输入http://127.0.0.1/index

成功输出；

继续添加login监听；

 View Code

 

看看结果：

其实这个自动注册我们目前依然需要重启服务；或者不够智能；

动态加载路由脚本；无需重启服务

 1 package net.sz.game.test.scripts.webapi;
 2 
 3 import java.util.ArrayList;
 4 import net.sz.game.engine.nio.nettys.http.NioHttpRequest;
 5 import net.sz.game.engine.scripts.manager.ScriptManager;
 6 import net.sz.game.engine.szlog.SzLogger;
 7 import net.sz.game.test.webapi.iscript.IWebApiScript;
 8 
 9 /**
10  *
11  * <br>
12  * author 失足程序员<br>
13  * blog http://www.cnblogs.com/ty408/<br>
14  * mail [e-mail]<br>
15  * phone [phone]<br>
16  */
17 public class ReloadScript implements IWebApiScript {
18 
19     private static SzLogger log = SzLogger.getLogger();
20 
21     @Override
22     public String getRoute() {
23         return "reload";
24     }
25 
26     @Override
27     public boolean action(String url, NioHttpRequest request) {
28         /*重新读取路由脚本*/
29         ArrayList<String> loadScripts = ScriptManager.getInstance().reload();
30         String join = "动态加载结果：" + String.join(",", loadScripts);
31         log.error(join);
32         request.addContent(join);
33         return true;
34     }
35 
36 }

 

reload监听里面处理脚本路由的更新操作；

之所以没有使用文件更新状态进行操作，是因为那样不可控；或许我现在只是发布，但是不需要更新；等待指定时间更新；

重新访问login

叙述

以上代码我们完成路由自动注册，

值的注意的有几点：

1，我们通过的脚本化实现的路由自动注册功能；所以代码是明文的，破坏危险，挂马危险，较高；

2，我没有加入验证机制；这个可以自行约定；确实了iis或tomcat的sesstion 和cokie的这种缓存机制；但好处在于可控性很高，不管是缓存，数据流向，自定义格式；不受iis或Tomcat限制；

3，但是我们可以做到动态发布，动态更新，在不重启服务的，不影响其他服务的情况下，划分出了，功能独立开发，独立部署，互不干涉的情况；

之所以我文章开头定义微服务也就是这个原理，可以实现服务接口的动态增加删除，独立开发，独立部署，单一流程；当然可以相互协调调用服务接口；

C#.net

在我的版本库或者叫框架里面依然实现了netty的调用的；

 1 using Net.Sz.Framework.Netty;
 2 using Net.Sz.Framework.Netty.Http;
 3 using System;
 4 using System.Collections.Generic;
 5 using System.Linq;
 6 using System.Text;
 7 using System.Threading.Tasks;
 8 
 9 namespace CApp_Webapi
10 {
11     class Program
12     {
13         static void Main(string[] args)
14         {
15 
16             HttpServer httpserver = NettyPool.AddHttpBind("127.0.0.1", 9527, 2);
17 
18             httpserver.AddHandler("*", new ActionHttpHandler((session) =>
19             {
20                 session.AddContent("<html><body>webapi！</body></html>");
21             }));
22 
23             httpserver.AddHandler("login", new ActionHttpHandler((session) =>
24             {
25                 session.AddContent("<html><body>login holle ！</body></html>");
26             }));
27 
28             httpserver.Start();
29 
30         }
31     }
32 }

 

所以就简单测试，不在过多的去实现和讲解理论，都是一样的；

C#版本，不管你是基于控制台项目，from项目还是service项目；都可以完美的运行；

总结

之前在iis里面创建static变量的共享数据的时候web项目在程序池没有被回收的情况下，static的资源没有了；需要加入到web.cache集合里面进行加载和调用；

同样也是，我是做游戏后端开发的，不管是socket的tcp协议还是socket的http协议，都需要进行处理；但是程序肯定是放在一起，不能经过iis等再次进行调用；

这篇文章在于，实现socket http请求，路由自动注册概念，微服务概念；已经脚本化的明文处理接口实现；

至于脚本的实现机制；大家可以查看框架代码或者翻看之前的文章，但是之前的文章里代码有很多已经和现在服务框架代码不经相同了；

C#版本的下面测试代码基本放在了

test的文件夹下面可以直接查看项目对应的测试代码；

java项目则有所不同，都是maven项目，每一个项目下面都有测试包；

已经测试程序；所以没有单独项目；