Java游戏服务器代码热更新

古城微笑少年丶 2022-06-01 02:27 435阅读 0赞

一般碰到这个问题首先想到的解决方案都是考虑new 一个classLoader来加载新的类，这样的解决方式有什么优点和缺点呢。
    
     
      
       1
       2

1.  使用ClassLoader的方式加载类就涉及到一些需要知道的知识点。双亲委托模型确保了一个类只会被一个类加载器加载一次，所以要更新旧的类就需要new一个新的类加载器。新的类可以添加字段添加方法还有很多强大的功能。如果仅仅只是一个简单的小程序是可以考虑的，毕竟牵涉到的模块不是很多，而且可以很方便的在线做更新。但是项目复杂起来之后，涉及到的模块依赖就会增加。如果一个类属性还有其他类的引用，那么这时还需要自己手动去设置值，可能还需要调用一些初始化方法，这样可能就很难去做一个通用处理了，当然如果一开始都遵循同样的初始化方法也是可以的。所以需要手动处理的东西比较多，而且程序中涉及到一些对象的比较可能就会出现各种问题，因为是不同的类加载器加载，不可控的东西很多。
2.  接下来就是思考还有没有其他的方式呢。java.lang.instrument这个类很早就出了，redefineClasses这个方法可以更新方法级别的代码，但是不会触发一个类的初始化方法。游戏服务器的bug基本上只需要方法级别的更新就可以了，因为很多重大的bug基本在测试阶段被修复了，少量偶线的bug出现之后有些时候仅仅只需要改动一行代码却有时不得不需要重启所有应用程序，代价都似乎有点大。
3.  现在开始从instrument入手

public static void premain(String agentArgs, Instrumentation inst);
     
      
       1

public static void agentmain(String agentArgs, Instrumentation inst);
     
      
       1

这两个方法都可以获取到Instrumentation对象，通过redefineClasses方法就可以更新对应的方法了   
如果是调用premain这个方法 则需要在程序启动的时候指定对应的jar 同时项目里必须引用这个jar 因为获取到这个引用   
java -javaagent:agent.jar -jar xx.jar 例如这样 执行这条命令后程序会查找 agent.jar 里的MANIFEST.MF文件里的Premain-Class参数 设置对应的代理类路径就行。例如：Premain-Class: com.test.JavaAgent 还需要加上 Can-Redefine-Classes: true这个参数才能调用redefineClasses方法。同时 可以拦截对应的类添加标记 做性能分析   
agentmain 是通过指定对应的进程pid来加载对应的agent.jar 很典型的jconsule jvisualvm都是通过选择java进程来做一个简单的内存 和cpu分析 ，线程dump .Agent-Class 和上面一样

package com.test;
    
    import java.lang.instrument.Instrumentation;
    
    public class JavaAgent { 
        public static Instrumentation INST = null;
    
        public static void premain(String agentArgs, Instrumentation inst){
            INST = inst;
        }
    }
    
     
      
       1
       2
       3
       4
       5
       6
       7
       8
       9
       10
       11
       12

这里保存下引用就可以了 ，单独打成agent.jar

package com.test;
    
    import java.io.FileInputStream;
    import java.lang.instrument.ClassDefinition;
    
    public class Test { 
    
        public static void main(String[] args) {
            getInfo();
            testhot();
        }
    
        public final static void testhot(){
            new Thread(new Runnable() {
    
                @Override
                public void run() {
                    // TODO Auto-generated method stub
                    while(true){
                        try {
                        if(JavaAgent.INST != null){
                            FileInputStream is = new FileInputStream("/Users/xxxx/Downloads/Student.class");
                            byte[] array = new byte[is.available()];
                            is.read(array);
                            is.close();
                            Class cls = Class.forName("com.test.Student");
                            JavaAgent.INST.redefineClasses(new ClassDefinition(cls,array));
                        }
                            Thread.sleep(1000);
                        } catch (Exception e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                        }
                    }
                }
            }).start();
        }
    
    
    
    
        public final static void getInfo(){
            new Thread(new Runnable() {
    
                @Override
                public void run() {
                    // TODO Auto-generated method stub
                    while(true){
                        //System.out.println("=============="+JavaAgent.INST);
                        new Student().getName();
                        try {
                            Thread.sleep(1000);
                        } catch (InterruptedException e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                        }
                    }
                }
            }).start();
    
        }
    }
    
     
      
       1
       2
       3
       4
       5
       6
       7
       8
       9
       10
       11
       12
       13
       14
       15
       16
       17
       18
       19
       20
       21
       22
       23
       24
       25
       26
       27
       28
       29
       30
       31
       32
       33
       34
       35
       36
       37
       38
       39
       40
       41
       42
       43
       44
       45
       46
       47
       48
       49
       50
       51
       52
       53
       54
       55
       56
       57
       58
       59
       60
       61
       62
       63

上面就是一个很简单的例子，一个线程在不停的循环检测更新这个类，另外的一个线程在不停的输出这个对象对应的方法输出信息。   
测试之后可以发现 ，方法的输出信息已经改变了。