golang使用信号量热更新的实现示例

哈丽

配置文件热更新是服务器程序的一个基本功能，通过热更新可以不停机调整程序的配置，特别是在生产环境可以提供极大的便利，比如发现log打得太多了可以动态调高日志等级，业务逻辑参数变化，甚至某个功能模块的开关等都可以动态调整。

1. package main  
   
2. import (
   
3.   "encoding/json"
   
4.   "fmt"
   
5.   "io/ioutil"
   
6.   "log"
   
7.   "os"
   
8.   "os/signal"
   
9.   "sync"
   
10.   "syscall"
    
11. )
    
12. 
    
13. //用json配置测试
    
14. type Config struct {
    
15.   Test1 string `json:"Test1:`
    
16.   Test2 int  `json:"Test1:`
    
17. }
    
18. 
    
19. var (
    
20.   config   *Config
    
21.   configLock = new(sync.RWMutex)
    
22. )
    
23. 
    
24. func loadConfig() bool {
    
25.   f, err := ioutil.ReadFile("config.json")
    
26.   if err != nil {
    
27.     fmt.Println("load config error: ", err)
    
28.     return false
    
29.   }
    
30. 
    
31.   //不同的配置规则，解析复杂度不同
    
32.   temp := new(Config)
    
33.   err = json.Unmarshal(f, &config)
    
34.   if err != nil {
    
35.     fmt.Println("Para config failed: ", err)
    
36.     return false
    
37.   }
    
38. 
    
39.   configLock.Lock()
    
40.   config = temp
    
41.   configLock.Unlock()
    
42.   return true
    
43. }
    
44. 
    
45. func GetConfig() *Config {
    
46.   configLock.RLock()
    
47.   defer configLock.RUnlock()
    
48.   return config
    
49. }
    
50. 
    
51. func init() {
    
52.   if !loadConfig() {
    
53.     os.Exit(1)
    
54.   }
    
55. 
    
56.   //热更新配置可能有多种触发方式，这里使用系统信号量sigusr1实现
    
57.   s := make(chan os.Signal, 1)
    
58.   signal.Notify(s, syscall.SIGUSR1)
    
59.   go func() {
    
60.     for {
    
61.       <-s
    
62.       log.Println("Reloaded config:", loadConfig())
    
63.     }
    
64.   }()
    
65. }
    
66. 
    
67. func main() {
    
68.   select {}
    
69. }

复制代码

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持晓枫资讯。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

邵振

感谢楼主，顶。

xymmo

感谢楼主分享。