-
Notifications
You must be signed in to change notification settings - Fork 0
/
index.html
1767 lines (870 loc) · 78.9 KB
/
index.html
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
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
836
837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
853
854
855
856
857
858
859
860
861
862
863
864
865
866
867
868
869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
885
886
887
888
889
890
891
892
893
894
895
896
897
898
899
900
901
902
903
904
905
906
907
908
909
910
911
912
913
914
915
916
917
918
919
920
921
922
923
924
925
926
927
928
929
930
931
932
933
934
935
936
937
938
939
940
941
942
943
944
945
946
947
948
949
950
951
952
953
954
955
956
957
958
959
960
961
962
963
964
965
966
967
968
969
970
971
972
973
974
975
976
977
978
979
980
981
982
983
984
985
986
987
988
989
990
991
992
993
994
995
996
997
998
999
1000
<!DOCTYPE html>
<html class="theme-next muse use-motion" lang="zh-CN">
<head><meta name="generator" content="Hexo 3.8.0">
<meta charset="UTF-8">
<meta http-equiv="X-UA-Compatible" content="IE=edge">
<meta name="viewport" content="width=device-width, initial-scale=1, maximum-scale=2">
<meta name="theme-color" content="#222">
<link rel="stylesheet" href="/lib/font-awesome/css/font-awesome.min.css?v=4.6.2">
<link rel="stylesheet" href="/css/main.css?v=7.0.1">
<link rel="apple-touch-icon" sizes="180x180" href="/images/apple-touch-icon-next.png?v=7.0.1">
<link rel="icon" type="image/png" sizes="32x32" href="/images/favicon-32x32-next.png?v=7.0.1">
<link rel="icon" type="image/png" sizes="16x16" href="/images/favicon-16x16-next.png?v=7.0.1">
<link rel="mask-icon" href="/images/logo.svg?v=7.0.1" color="#222">
<script id="hexo.configurations">
var NexT = window.NexT || {};
var CONFIG = {
root: '/',
scheme: 'Muse',
version: '7.0.1',
sidebar: {"position":"left","display":"post","offset":12,"onmobile":false,"dimmer":false},
back2top: true,
back2top_sidebar: false,
fancybox: false,
fastclick: false,
lazyload: false,
tabs: true,
motion: {"enable":true,"async":false,"transition":{"post_block":"fadeIn","post_header":"slideDownIn","post_body":"slideDownIn","coll_header":"slideLeftIn","sidebar":"slideUpIn"}},
algolia: {
applicationID: '',
apiKey: '',
indexName: '',
hits: {"per_page":10},
labels: {"input_placeholder":"Search for Posts","hits_empty":"We didn't find any results for the search: ${query}","hits_stats":"${hits} results found in ${time} ms"}
}
};
</script>
<meta property="og:type" content="website">
<meta property="og:title" content="Eightmonth">
<meta property="og:url" content="https://kezhijie.org/index.html">
<meta property="og:site_name" content="Eightmonth">
<meta property="og:locale" content="zh-CN">
<meta name="twitter:card" content="summary">
<meta name="twitter:title" content="Eightmonth">
<link rel="canonical" href="https://kezhijie.org/">
<script id="page.configurations">
CONFIG.page = {
sidebar: "",
};
</script>
<title>Eightmonth</title>
<noscript>
<style>
.use-motion .motion-element,
.use-motion .brand,
.use-motion .menu-item,
.sidebar-inner,
.use-motion .post-block,
.use-motion .pagination,
.use-motion .comments,
.use-motion .post-header,
.use-motion .post-body,
.use-motion .collection-title { opacity: initial; }
.use-motion .logo,
.use-motion .site-title,
.use-motion .site-subtitle {
opacity: initial;
top: initial;
}
.use-motion .logo-line-before i { left: initial; }
.use-motion .logo-line-after i { right: initial; }
</style>
</noscript>
</head>
<body itemscope="" itemtype="http://schema.org/WebPage" lang="zh-CN">
<div class="container sidebar-position-left
page-home">
<div class="headband"></div>
<header id="header" class="header" itemscope="" itemtype="http://schema.org/WPHeader">
<div class="header-inner"><div class="site-brand-wrapper">
<div class="site-meta">
<div class="custom-logo-site-title">
<a href="/" class="brand" rel="start">
<span class="logo-line-before"><i></i></span>
<span class="site-title">Eightmonth</span>
<span class="logo-line-after"><i></i></span>
</a>
</div>
</div>
<div class="site-nav-toggle">
<button aria-label="切换导航栏">
<span class="btn-bar"></span>
<span class="btn-bar"></span>
<span class="btn-bar"></span>
</button>
</div>
</div>
<nav class="site-nav">
<ul id="menu" class="menu">
<li class="menu-item menu-item-home menu-item-active">
<a href="/" rel="section"><i class="menu-item-icon fa fa-fw fa-home"></i> <br>首页</a>
</li>
<li class="menu-item menu-item-archives">
<a href="/archives/" rel="section"><i class="menu-item-icon fa fa-fw fa-archive"></i> <br>归档<span class="badge">4</span></a>
</li>
<li class="menu-item menu-item-search">
<a href="javascript:;" class="popup-trigger">
<i class="menu-item-icon fa fa-search fa-fw"></i> <br>搜索</a>
</li>
</ul>
<div class="site-search">
<div class="popup search-popup local-search-popup">
<div class="local-search-header clearfix">
<span class="search-icon">
<i class="fa fa-search"></i>
</span>
<span class="popup-btn-close">
<i class="fa fa-times-circle"></i>
</span>
<div class="local-search-input-wrapper">
<input autocomplete="off" placeholder="搜索..." spellcheck="false" type="text" id="local-search-input">
</div>
</div>
<div id="local-search-result"></div>
</div>
</div>
</nav>
</div>
</header>
<main id="main" class="main">
<div class="main-inner">
<div class="content-wrap">
<div id="content" class="content">
<section id="posts" class="posts-expand">
<article class="post post-type-normal" itemscope="" itemtype="http://schema.org/Article">
<div class="post-block">
<link itemprop="mainEntityOfPage" href="https://kezhijie.org/2019/03/28/XXL-JOB EXECUTOR 源码解析/">
<span hidden itemprop="author" itemscope="" itemtype="http://schema.org/Person">
<meta itemprop="name" content="Eightmonth | 柯志杰">
<meta itemprop="description" content="">
<meta itemprop="image" content="/images/avatar.gif">
</span>
<span hidden itemprop="publisher" itemscope="" itemtype="http://schema.org/Organization">
<meta itemprop="name" content="Eightmonth">
</span>
<header class="post-header">
<h1 class="post-title" itemprop="name headline">
<a href="/2019/03/28/XXL-JOB EXECUTOR 源码解析/" class="post-title-link" itemprop="url">XXL-JOB EXECUTOR 源码解析</a>
</h1>
<div class="post-meta">
<span class="post-time">
<span class="post-meta-item-icon">
<i class="fa fa-calendar-o"></i>
</span>
<span class="post-meta-item-text">发表于</span>
<time title="创建时间：2019-03-28 14:39:20" itemprop="dateCreated datePublished" datetime="2019-03-28T14:39:20+08:00">2019-03-28</time>
</span>
<span class="post-category">
<span class="post-meta-divider">|</span>
<span class="post-meta-item-icon">
<i class="fa fa-folder-o"></i>
</span>
<span class="post-meta-item-text">分类于</span>
<span itemprop="about" itemscope="" itemtype="http://schema.org/Thing"><a href="/categories/Scheduler/" itemprop="url" rel="index"><span itemprop="name">Scheduler</span></a></span>
，
<span itemprop="about" itemscope="" itemtype="http://schema.org/Thing"><a href="/categories/Scheduler/XXL-JOB/" itemprop="url" rel="index"><span itemprop="name">XXL-JOB</span></a></span>
</span>
</div>
</header>
<div class="post-body" itemprop="articleBody">
<h1 id="XXL-JOB-EXECUTOR-源码解析"><a href="#XXL-JOB-EXECUTOR-源码解析" class="headerlink" title="XXL-JOB EXECUTOR 源码解析"></a>XXL-JOB EXECUTOR 源码解析</h1><blockquote>
<p>xxl-job 是一个分布式调度框架，同时具备GLUE特性。</p>
<p>xxl-job 分两部分，一为执行器，二为调度器，执行器的职责是具体的作业，而调度器的职责是接收原生配置的调度策略进行任务调度执行器作业。</p>
<p>此文专门讲解执行器部分，全文围绕<code>spring boot</code>环境讲解。</p>
<p>xxl-job version: 2.0.2-SNAPSHOT</p>
<p>官方地址：<a href="http://www.xuxueli.com/xxl-job/#/" target="_blank" rel="noopener">http://www.xuxueli.com/xxl-job/#/</a></p>
<p>解决了哪些问题：</p>
<ol>
<li>统一管理分布式环境下的定时任务</li>
<li>界面化管理，清晰查看每一个任务的情况</li>
<li>监控任务执行情况及实时dashboard</li>
<li>集群调用、集群执行，具备HA及去除多余的分布式锁</li>
</ol>
</blockquote>
<h3 id="调用顺序"><a href="#调用顺序" class="headerlink" title="调用顺序"></a>调用顺序</h3><ol>
<li>加载配置</li>
</ol>
<figure class="highlight java"><table><tr><td class="gutter"><pre><span class="line">1</span><br><span class="line">2</span><br><span class="line">3</span><br><span class="line">4</span><br><span class="line">5</span><br><span class="line">6</span><br><span class="line">7</span><br><span class="line">8</span><br><span class="line">9</span><br><span class="line">10</span><br><span class="line">11</span><br><span class="line">12</span><br><span class="line">13</span><br><span class="line">14</span><br><span class="line">15</span><br><span class="line">16</span><br><span class="line">17</span><br><span class="line">18</span><br><span class="line">19</span><br><span class="line">20</span><br><span class="line">21</span><br><span class="line">22</span><br><span class="line">23</span><br><span class="line">24</span><br><span class="line">25</span><br><span class="line">26</span><br><span class="line">27</span><br><span class="line">28</span><br><span class="line">29</span><br><span class="line">30</span><br><span class="line">31</span><br><span class="line">32</span><br><span class="line">33</span><br><span class="line">34</span><br><span class="line">35</span><br><span class="line">36</span><br><span class="line">37</span><br><span class="line">38</span><br><span class="line">39</span><br><span class="line">40</span><br><span class="line">41</span><br><span class="line">42</span><br><span class="line">43</span><br><span class="line">44</span><br><span class="line">45</span><br><span class="line">46</span><br><span class="line">47</span><br><span class="line">48</span><br></pre></td><td class="code"><pre><span class="line"><span class="comment">/**</span></span><br><span class="line"><span class="comment"> * xxl-job config</span></span><br><span class="line"><span class="comment"> *</span></span><br><span class="line"><span class="comment"> * <span class="doctag">@author</span> xuxueli 2017-04-28</span></span><br><span class="line"><span class="comment"> */</span></span><br><span class="line"><span class="meta">@Configuration</span></span><br><span class="line"><span class="meta">@ComponentScan</span>(basePackages = <span class="string">"com.xxl.job.executor.service.jobhandler"</span>)</span><br><span class="line"><span class="keyword">public</span> <span class="class"><span class="keyword">class</span> <span class="title">XxlJobConfig</span> </span>{</span><br><span class="line"> <span class="keyword">private</span> Logger logger = LoggerFactory.getLogger(XxlJobConfig.class);</span><br><span class="line"></span><br><span class="line"> <span class="meta">@Value</span>(<span class="string">"${xxl.job.admin.addresses}"</span>)</span><br><span class="line"> <span class="keyword">private</span> String adminAddresses;</span><br><span class="line"></span><br><span class="line"> <span class="meta">@Value</span>(<span class="string">"${xxl.job.executor.appname}"</span>)</span><br><span class="line"> <span class="keyword">private</span> String appName;</span><br><span class="line"></span><br><span class="line"> <span class="meta">@Value</span>(<span class="string">"${xxl.job.executor.ip}"</span>)</span><br><span class="line"> <span class="keyword">private</span> String ip;</span><br><span class="line"></span><br><span class="line"> <span class="meta">@Value</span>(<span class="string">"${xxl.job.executor.port}"</span>)</span><br><span class="line"> <span class="keyword">private</span> <span class="keyword">int</span> port;</span><br><span class="line"></span><br><span class="line"> <span class="meta">@Value</span>(<span class="string">"${xxl.job.accessToken}"</span>)</span><br><span class="line"> <span class="keyword">private</span> String accessToken;</span><br><span class="line"></span><br><span class="line"> <span class="meta">@Value</span>(<span class="string">"${xxl.job.executor.logpath}"</span>)</span><br><span class="line"> <span class="keyword">private</span> String logPath;</span><br><span class="line"></span><br><span class="line"> <span class="meta">@Value</span>(<span class="string">"${xxl.job.executor.logretentiondays}"</span>)</span><br><span class="line"> <span class="keyword">private</span> <span class="keyword">int</span> logRetentionDays;</span><br><span class="line"></span><br><span class="line"></span><br><span class="line"> <span class="meta">@Bean</span>(initMethod = <span class="string">"start"</span>, destroyMethod = <span class="string">"destroy"</span>)</span><br><span class="line"> <span class="function"><span class="keyword">public</span> XxlJobSpringExecutor <span class="title">xxlJobExecutor</span><span class="params">()</span> </span>{</span><br><span class="line"> logger.info(<span class="string">">>>>>>>>>>> xxl-job config init."</span>);</span><br><span class="line"> XxlJobSpringExecutor xxlJobSpringExecutor = <span class="keyword">new</span> XxlJobSpringExecutor();</span><br><span class="line"> xxlJobSpringExecutor.setAdminAddresses(adminAddresses);</span><br><span class="line"> xxlJobSpringExecutor.setAppName(appName);</span><br><span class="line"> xxlJobSpringExecutor.setIp(ip);</span><br><span class="line"> xxlJobSpringExecutor.setPort(port);</span><br><span class="line"> xxlJobSpringExecutor.setAccessToken(accessToken);</span><br><span class="line"> xxlJobSpringExecutor.setLogPath(logPath);</span><br><span class="line"> xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);</span><br><span class="line"></span><br><span class="line"> <span class="keyword">return</span> xxlJobSpringExecutor;</span><br><span class="line"> }</span><br><span class="line"></span><br><span class="line">}</span><br></pre></td></tr></table></figure>
<ol start="2">
<li>利用<code>spring</code>的初始化进入到<code>com.xxl.job.core.executor.impl.XxlJobSpringExecutor#start</code>方法中</li>
</ol>
<figure class="highlight java"><table><tr><td class="gutter"><pre><span class="line">1</span><br><span class="line">2</span><br><span class="line">3</span><br><span class="line">4</span><br><span class="line">5</span><br><span class="line">6</span><br><span class="line">7</span><br><span class="line">8</span><br><span class="line">9</span><br><span class="line">10</span><br><span class="line">11</span><br><span class="line">12</span><br><span class="line">13</span><br><span class="line">14</span><br><span class="line">15</span><br><span class="line">16</span><br><span class="line">17</span><br><span class="line">18</span><br><span class="line">19</span><br><span class="line">20</span><br><span class="line">21</span><br><span class="line">22</span><br><span class="line">23</span><br><span class="line">24</span><br><span class="line">25</span><br><span class="line">26</span><br><span class="line">27</span><br><span class="line">28</span><br><span class="line">29</span><br><span class="line">30</span><br><span class="line">31</span><br><span class="line">32</span><br><span class="line">33</span><br><span class="line">34</span><br><span class="line">35</span><br><span class="line">36</span><br><span class="line">37</span><br><span class="line">38</span><br><span class="line">39</span><br><span class="line">40</span><br><span class="line">41</span><br><span class="line">42</span><br><span class="line">43</span><br><span class="line">44</span><br><span class="line">45</span><br><span class="line">46</span><br><span class="line">47</span><br><span class="line">48</span><br><span class="line">49</span><br><span class="line">50</span><br><span class="line">51</span><br><span class="line">52</span><br><span class="line">53</span><br><span class="line">54</span><br><span class="line">55</span><br></pre></td><td class="code"><pre><span class="line"><span class="comment">/**</span></span><br><span class="line"><span class="comment"> * xxl-job executor (for spring)</span></span><br><span class="line"><span class="comment"> *</span></span><br><span class="line"><span class="comment"> * <span class="doctag">@author</span> xuxueli 2018-11-01 09:24:52</span></span><br><span class="line"><span class="comment"> */</span></span><br><span class="line"><span class="keyword">public</span> <span class="class"><span class="keyword">class</span> <span class="title">XxlJobSpringExecutor</span> <span class="keyword">extends</span> <span class="title">XxlJobExecutor</span> <span class="keyword">implements</span> <span class="title">ApplicationContextAware</span> </span>{</span><br><span class="line"></span><br><span class="line"></span><br><span class="line"> <span class="meta">@Override</span></span><br><span class="line"> <span class="function"><span class="keyword">public</span> <span class="keyword">void</span> <span class="title">start</span><span class="params">()</span> <span class="keyword">throws</span> Exception </span>{</span><br><span class="line"></span><br><span class="line"> <span class="comment">// 初始化JobHandler仓库</span></span><br><span class="line"> initJobHandlerRepository(applicationContext);</span><br><span class="line"></span><br><span class="line"> <span class="comment">// 刷新Glue工厂</span></span><br><span class="line"> GlueFactory.refreshInstance(<span class="number">1</span>);</span><br><span class="line"></span><br><span class="line"></span><br><span class="line"> <span class="comment">// 继续调用核心库提供的加载方法</span></span><br><span class="line"> <span class="keyword">super</span>.start();</span><br><span class="line"> }</span><br><span class="line"></span><br><span class="line"> <span class="function"><span class="keyword">private</span> <span class="keyword">void</span> <span class="title">initJobHandlerRepository</span><span class="params">(ApplicationContext applicationContext)</span></span>{</span><br><span class="line"> <span class="keyword">if</span> (applicationContext == <span class="keyword">null</span>) {</span><br><span class="line"> <span class="keyword">return</span>;</span><br><span class="line"> }</span><br><span class="line"></span><br><span class="line"> <span class="comment">// 开始构建JobHandler</span></span><br><span class="line"> Map<String, Object> serviceBeanMap = applicationContext.getBeansWithAnnotation(JobHandler.class);</span><br><span class="line"></span><br><span class="line"> <span class="keyword">if</span> (serviceBeanMap!=<span class="keyword">null</span> && serviceBeanMap.size()><span class="number">0</span>) {</span><br><span class="line"> <span class="keyword">for</span> (Object serviceBean : serviceBeanMap.values()) {</span><br><span class="line"> <span class="keyword">if</span> (serviceBean <span class="keyword">instanceof</span> IJobHandler){</span><br><span class="line"> String name = serviceBean.getClass().getAnnotation(JobHandler.class).value();</span><br><span class="line"> IJobHandler handler = (IJobHandler) serviceBean;</span><br><span class="line"> <span class="keyword">if</span> (loadJobHandler(name) != <span class="keyword">null</span>) { <span class="comment">// 名称去重</span></span><br><span class="line"> <span class="keyword">throw</span> <span class="keyword">new</span> RuntimeException(<span class="string">"xxl-job jobhandler naming conflicts."</span>);</span><br><span class="line"> }</span><br><span class="line"> registJobHandler(name, handler);</span><br><span class="line"> }</span><br><span class="line"> }</span><br><span class="line"> }</span><br><span class="line"> }</span><br><span class="line"></span><br><span class="line"> <span class="comment">// ---------------------- applicationContext ----------------------</span></span><br><span class="line"> <span class="keyword">private</span> <span class="keyword">static</span> ApplicationContext applicationContext;</span><br><span class="line"> <span class="meta">@Override</span></span><br><span class="line"> <span class="function"><span class="keyword">public</span> <span class="keyword">void</span> <span class="title">setApplicationContext</span><span class="params">(ApplicationContext applicationContext)</span> <span class="keyword">throws</span> BeansException </span>{</span><br><span class="line"> <span class="keyword">this</span>.applicationContext = applicationContext;</span><br><span class="line"> }</span><br><span class="line"> <span class="function"><span class="keyword">public</span> <span class="keyword">static</span> ApplicationContext <span class="title">getApplicationContext</span><span class="params">()</span> </span>{</span><br><span class="line"> <span class="keyword">return</span> applicationContext;</span><br><span class="line"> }</span><br><span class="line"></span><br><span class="line">}</span><br></pre></td></tr></table></figure>
<p>可以看到，<code>start</code>方法很具体的分为三步：</p>
<ol>
<li>加载<code>Jobhandler</code></li>
<li>根据参数刷新<code>GLUE</code>工厂</li>
<li>调用核心库加载方法</li>
</ol>
<p>先具体看第一步：</p>
<p>根据<code>spring</code>容器提供的<code>ApplicationContext</code>扫描并读取所有注解了<code>@JobHandler</code>的<code>Bean</code>， 以注解<code>@JobHandler</code>的值作为<code>JobHandler</code>的名称，并且做了名称去重检查，然后再加入到由<code>xxl-job</code>框架维护的<code>JobHandler</code>仓库中，到此，<code>JobHandler</code>加载完毕。</p>
<p>由此，也可以得出扩展，只要你能办法把你的<code>Bean</code>并且带一个名称加入到这个由<code>xxl-job</code>框架维护的<code>JobHandler</code>仓库中，那么即使你没有经过前面的那些步骤，你这个<code>Bean</code>也是一个合法的<code>JobHandler</code>。而正好，这个<code>JobHandler</code>仓库提供了开放的访问方式，如下：</p>
<figure class="highlight java"><table><tr><td class="gutter"><pre><span class="line">1</span><br><span class="line">2</span><br><span class="line">3</span><br><span class="line">4</span><br></pre></td><td class="code"><pre><span class="line"><span class="comment">// 注入JobHandler</span></span><br><span class="line">XxlJobExecutor.registJobHandler(String name, IJobHandler jobHandler);</span><br><span class="line"><span class="comment">// 获取JobHandler</span></span><br><span class="line">XxlJobExecutor.loadJobHandler(String name);</span><br></pre></td></tr></table></figure>
<p>再来看第二步：</p>
<p>第二步相对来说步骤比较简单，根据参数刷新<code>GLUE</code>工厂，其实就是初始化一个工厂，目前只接受<code>0</code>和<code>1</code>两个参数：</p>
<p><code>0</code>：初始化一个普通的<code>GLUE</code>工厂，依赖反射生成对象，同时使用<code>GROOVY</code>类加载器编译。</p>
<p><code>1</code>：初始化一个<code>Spring</code>的<code>GLUE</code>工厂，依赖<code>Spring</code>获取对象。</p>
<p>最后再来看第三步：</p>
<p>这里开始使用前面提到的那些配置，其实前面的绝大多数配置都是有默认值可以不填的，甚至连<code>ip</code>、<code>port</code>都是可以不提供的。真正需要填的只有两个参数<code>xxl.job.executor.appname</code>、<code>xxl.job.admin.addresses</code>，然而当接入了<code>spring-cloud-common</code>依赖后，你这两个参数也可以不填了，这部分将在后面讲解，<code>spring cloud</code>环境无缝集成<code>xxl-job</code>。</p>
<figure class="highlight java"><table><tr><td class="gutter"><pre><span class="line">1</span><br><span class="line">2</span><br><span class="line">3</span><br><span class="line">4</span><br><span class="line">5</span><br><span class="line">6</span><br><span class="line">7</span><br><span class="line">8</span><br><span class="line">9</span><br><span class="line">10</span><br><span class="line">11</span><br><span class="line">12</span><br><span class="line">13</span><br><span class="line">14</span><br><span class="line">15</span><br><span class="line">16</span><br><span class="line">17</span><br><span class="line">18</span><br><span class="line">19</span><br><span class="line">20</span><br><span class="line">21</span><br><span class="line">22</span><br><span class="line">23</span><br><span class="line">24</span><br><span class="line">25</span><br><span class="line">26</span><br><span class="line">27</span><br><span class="line">28</span><br><span class="line">29</span><br><span class="line">30</span><br><span class="line">31</span><br><span class="line">32</span><br><span class="line">33</span><br><span class="line">34</span><br><span class="line">35</span><br><span class="line">36</span><br><span class="line">37</span><br><span class="line">38</span><br><span class="line">39</span><br><span class="line">40</span><br><span class="line">41</span><br><span class="line">42</span><br><span class="line">43</span><br><span class="line">44</span><br><span class="line">45</span><br><span class="line">46</span><br><span class="line">47</span><br><span class="line">48</span><br><span class="line">49</span><br><span class="line">50</span><br><span class="line">51</span><br><span class="line">52</span><br><span class="line">53</span><br><span class="line">54</span><br><span class="line">55</span><br><span class="line">56</span><br><span class="line">57</span><br></pre></td><td class="code"><pre><span class="line"><span class="comment">/**</span></span><br><span class="line"><span class="comment"> * Created by xuxueli on 2016/3/2 21:14.</span></span><br><span class="line"><span class="comment"> */</span></span><br><span class="line"><span class="keyword">public</span> <span class="class"><span class="keyword">class</span> <span class="title">XxlJobExecutor</span> </span>{</span><br><span class="line"> <span class="keyword">private</span> <span class="keyword">static</span> <span class="keyword">final</span> Logger logger = LoggerFactory.getLogger(XxlJobExecutor.class);</span><br><span class="line"></span><br><span class="line"> <span class="comment">// ---------------------- param ----------------------</span></span><br><span class="line"> <span class="keyword">private</span> String adminAddresses;</span><br><span class="line"> <span class="keyword">private</span> String appName;</span><br><span class="line"> <span class="keyword">private</span> String ip;</span><br><span class="line"> <span class="keyword">private</span> <span class="keyword">int</span> port;</span><br><span class="line"> <span class="keyword">private</span> String accessToken;</span><br><span class="line"> <span class="keyword">private</span> String logPath;</span><br><span class="line"> <span class="keyword">private</span> <span class="keyword">int</span> logRetentionDays;</span><br><span class="line"></span><br><span class="line"> <span class="comment">// ---------------------- start + stop ----------------------</span></span><br><span class="line"> <span class="function"><span class="keyword">public</span> <span class="keyword">void</span> <span class="title">start</span><span class="params">()</span> <span class="keyword">throws</span> Exception </span>{</span><br><span class="line"></span><br><span class="line"> <span class="comment">// 配置日志路径</span></span><br><span class="line"> XxlJobFileAppender.initLogPath(logPath);</span><br><span class="line"></span><br><span class="line"> <span class="comment">// 构建调度器客户端</span></span><br><span class="line"> initAdminBizList(adminAddresses, accessToken);</span><br><span class="line"></span><br><span class="line"></span><br><span class="line"> <span class="comment">// 配置日志清理线程（daemon）</span></span><br><span class="line"> JobLogFileCleanThread.getInstance().start(logRetentionDays);</span><br><span class="line"></span><br><span class="line"> <span class="comment">// 构建触发回调线程</span></span><br><span class="line"> TriggerCallbackThread.getInstance().start();</span><br><span class="line"></span><br><span class="line"> <span class="comment">// 构建执行器服务端（正式开启对外提供访问入口）</span></span><br><span class="line"> port = port><span class="number">0</span>?port: NetUtil.findAvailablePort(<span class="number">9999</span>);</span><br><span class="line"> ip = (ip!=<span class="keyword">null</span>&&ip.trim().length()><span class="number">0</span>)?ip: IpUtil.getIp();</span><br><span class="line"> initRpcProvider(ip, port, appName, accessToken);</span><br><span class="line"> }</span><br><span class="line"> </span><br><span class="line"> <span class="function"><span class="keyword">public</span> <span class="keyword">void</span> <span class="title">destroy</span><span class="params">()</span></span>{</span><br><span class="line"> <span class="comment">// 销毁作业仓库线程</span></span><br><span class="line"> <span class="keyword">if</span> (jobThreadRepository.size() > <span class="number">0</span>) {</span><br><span class="line"> <span class="keyword">for</span> (Map.Entry<Integer, JobThread> item: jobThreadRepository.entrySet()) {</span><br><span class="line"> removeJobThread(item.getKey(), <span class="string">"web容器销毁然后终止作业."</span>);</span><br><span class="line"> }</span><br><span class="line"> jobThreadRepository.clear();</span><br><span class="line"> }</span><br><span class="line"></span><br><span class="line"></span><br><span class="line"> <span class="comment">// 销毁日志清理线程</span></span><br><span class="line"> JobLogFileCleanThread.getInstance().toStop();</span><br><span class="line"></span><br><span class="line"> <span class="comment">// 销毁触发回调线程</span></span><br><span class="line"> TriggerCallbackThread.getInstance().toStop();</span><br><span class="line"></span><br><span class="line"> <span class="comment">// 销毁执行器服务端（正式关闭对外访问入口）</span></span><br><span class="line"> stopRpcProvider();</span><br><span class="line"> }</span><br><span class="line">}</span><br></pre></td></tr></table></figure>
<p><code>start</code>方法：</p>
<ol>
<li>配置日志路径</li>
</ol>
<p><code>xxl.job.executor.logpath</code>参数定义日志路径，默认值为：<code>/data/applogs/xxl-job/jobhandler/gluesource</code></p>
<ol start="2">
<li>构建调度器客户端</li>
</ol>
<p>根据<code>xxl.job.admin.addresses</code>生成一个<code>RPC</code>调用对象，而最终<code>RPC</code>的调用对象的地址是拼接了一个<code>/api</code>，使用<code>Jetty</code>的网络包和<code>Hessian</code>的序列化。</p>
<ol start="3">
<li>配置日志清理线程</li>
</ol>
<p>日志保留天数最少保留4天，否则永久保留。</p>
<ol start="4">
<li>构建触发回调线程</li>
</ol>
<p>调度器调用执行器执行结束后，反馈结果给调度器</p>
<ol start="5">
<li>构建执行客户端</li>
</ol>
<p>构建外部可以访问的web入口，向调度器注册自身，提供被调度的入口。</p>
</div>
<footer class="post-footer">
<div class="post-eof"></div>
</footer>
</div>
</article>
<article class="post post-type-normal" itemscope="" itemtype="http://schema.org/Article">
<div class="post-block">
<link itemprop="mainEntityOfPage" href="https://kezhijie.org/2019/01/31/Spring Boot 初始化及加载/">
<span hidden itemprop="author" itemscope="" itemtype="http://schema.org/Person">
<meta itemprop="name" content="Eightmonth | 柯志杰">
<meta itemprop="description" content="">
<meta itemprop="image" content="/images/avatar.gif">
</span>
<span hidden itemprop="publisher" itemscope="" itemtype="http://schema.org/Organization">
<meta itemprop="name" content="Eightmonth">
</span>
<header class="post-header">
<h1 class="post-title" itemprop="name headline">
<a href="/2019/01/31/Spring Boot 初始化及加载/" class="post-title-link" itemprop="url">Spring Boot 初始化及加载</a>
</h1>
<div class="post-meta">
<span class="post-time">
<span class="post-meta-item-icon">
<i class="fa fa-calendar-o"></i>
</span>
<span class="post-meta-item-text">发表于</span>
<time title="创建时间：2019-01-31 14:59:46" itemprop="dateCreated datePublished" datetime="2019-01-31T14:59:46+08:00">2019-01-31</time>
</span>
<span class="post-category">
<span class="post-meta-divider">|</span>
<span class="post-meta-item-icon">
<i class="fa fa-folder-o"></i>
</span>
<span class="post-meta-item-text">分类于</span>
<span itemprop="about" itemscope="" itemtype="http://schema.org/Thing"><a href="/categories/Spring-boot/" itemprop="url" rel="index"><span itemprop="name">Spring boot</span></a></span>
</span>
</div>
</header>
<div class="post-body" itemprop="articleBody">
<h2 id="Spring-Boot-初始化及加载"><a href="#Spring-Boot-初始化及加载" class="headerlink" title="Spring Boot 初始化及加载"></a>Spring Boot 初始化及加载</h2><h4 id="1-设置开关"><a href="#1-设置开关" class="headerlink" title="1. 设置开关"></a>1. 设置开关</h4><p>bannerMode (横幅模式，默认为CONSOLE)</p>
<p>logStartupInfo (日志开关，默认为true)</p>
<p>addCommandLineProperties (添加命令行属性开关，默认为true)</p>
<p>headless (程序运行模式，java.jwt.headless=true)</p>
<p>registerShutdownHook (注册销毁回调，默认为true)</p>
<h4 id="2-初始化profile容器"><a href="#2-初始化profile容器" class="headerlink" title="2.初始化profile容器"></a>2.初始化profile容器</h4><p>存储当前激活的profile</p>
<h4 id="3-初始化"><a href="#3-初始化" class="headerlink" title="3.初始化"></a>3.初始化</h4><h5 id="3-1-推断运行环境"><a href="#3-1-推断运行环境" class="headerlink" title="3.1 推断运行环境"></a>3.1 推断运行环境</h5><p>首先判定classpath下是否包含<code>javax.servlet.Servlet</code>类或<code>org.springframework.web.context.ConfigurableWebApplicationContext</code>类，若包含二者其中一个，则推断当前程序为web程序</p>
<h5 id="3-2-初始化初始工厂类"><a href="#3-2-初始化初始工厂类" class="headerlink" title="3.2 初始化初始工厂类"></a>3.2 初始化初始工厂类</h5><p>加载在<code>classpath:META-INF/spring.factories</code>文件中属性<code>key</code>为<code>org.springframework.context.ApplicationContextInitializer</code>的值——工厂类的全限定名</p>
<h5 id="3-3-初始化容器监听"><a href="#3-3-初始化容器监听" class="headerlink" title="3.3 初始化容器监听"></a>3.3 初始化容器监听</h5><p>加载在<code>classpath:META-INF/spring.factories</code>文件中属性<code>key</code>为<code>org.springframework.context.ApplicationListener</code>的值——容器监听的全限定名</p>
<h5 id="3-4-推断程序入口主类"><a href="#3-4-推断程序入口主类" class="headerlink" title="3.4 推断程序入口主类"></a>3.4 推断程序入口主类</h5><p>根据栈帧推断程序入口类</p>
<h4 id="4-加载"><a href="#4-加载" class="headerlink" title="4.加载"></a>4.加载</h4><h5 id="4-1-注册StopWatch并打开"><a href="#4-1-注册StopWatch并打开" class="headerlink" title="4.1 注册StopWatch并打开"></a>4.1 注册<code>StopWatch</code>并打开</h5><h5 id="4-2-初始化环境配置容器"><a href="#4-2-初始化环境配置容器" class="headerlink" title="4.2 初始化环境配置容器"></a>4.2 初始化环境配置容器</h5><h5 id="4-3-初始化失败分析器"><a href="#4-3-初始化失败分析器" class="headerlink" title="4.3 初始化失败分析器"></a>4.3 初始化失败分析器</h5><h5 id="4-4-响应程序运行模式（前面提到的-java-awt-headless，这里不扩展此点，自行查阅资料）"><a href="#4-4-响应程序运行模式（前面提到的-java-awt-headless，这里不扩展此点，自行查阅资料）" class="headerlink" title="4.4 响应程序运行模式（前面提到的 java.awt.headless，这里不扩展此点，自行查阅资料）"></a>4.4 响应程序运行模式（前面提到的 java.awt.headless，这里不扩展此点，自行查阅资料）</h5><h5 id="4-5-加载spring-boot监听"><a href="#4-5-加载spring-boot监听" class="headerlink" title="4.5 加载spring boot监听"></a>4.5 加载spring boot监听</h5><p>加载在<code>classpath:META-INF/spring.factories</code>文件中属性<code>key</code>为<code>org.springframework.boot.SpringApplicationRunListener</code>的值——spring boot监听的全限定名</p>
<h5 id="4-6-加载应用参数"><a href="#4-6-加载应用参数" class="headerlink" title="4.6 加载应用参数"></a>4.6 加载应用参数</h5><p>根据程序入口<code>main（String[] args）</code>中的参数配置对应的应用参数，等到应用参数对象。</p>
<h5 id="4-7-根据应用参数及spring-boot监听配置环境并提供环境配置对象"><a href="#4-7-根据应用参数及spring-boot监听配置环境并提供环境配置对象" class="headerlink" title="4.7 根据应用参数及spring boot监听配置环境并提供环境配置对象"></a>4.7 根据应用参数及<code>spring boot</code>监听配置环境并提供环境配置对象</h5><p>获取或创建环境容器</p>
<p>加载配置文件并根据<code>spring.profiles.active</code>加载profile</p>
<p>加载配置文件并触发<code>环境前监听</code></p>
<h5 id="4-8-打印横幅"><a href="#4-8-打印横幅" class="headerlink" title="4.8 打印横幅"></a>4.8 打印横幅</h5><h5 id="4-9-创建ApplicationContext"><a href="#4-9-创建ApplicationContext" class="headerlink" title="4.9 创建ApplicationContext"></a>4.9 创建ApplicationContext</h5><h5 id="4-10-创建失败分析器"><a href="#4-10-创建失败分析器" class="headerlink" title="4.10 创建失败分析器"></a>4.10 创建失败分析器</h5><p>加载在<code>classpath:META-INF/spring.factories</code>文件中属性<code>key</code>为<code>org.springframework.boot.diagnostics.FailureAnalyzer</code>的值——失败分析器的全限定名，</p>
<p>并且注入<code>BeanFactory</code>。</p>
<p>注意，此失败分析器与4.3提到的并不是一个失败分析器，当前创建失败分析器为配置<code>spring.factories</code>中的失败分析器。</p>
<h5 id="4-11-前置配置ApplicationContext"><a href="#4-11-前置配置ApplicationContext" class="headerlink" title="4.11 前置配置ApplicationContext"></a>4.11 前置配置ApplicationContext</h5><p>注入前面构建好的环境对象到<code>ApplicationContext</code></p>
<p>根据<code>BeanNamedGenerator</code>和<code>ResourceLoader</code>后置处理ApplicationContext</p>
<p>应用所有初始化器</p>
<p>响应应用上下文前置监听</p>
<p>初始化日志对象</p>
<p>把应用参数对象加入到容器中</p>
<p>加载所有资源到<code>ApplicationContext</code></p>
<p>响应应用加载时监听</p>
<h5 id="4-12-刷新ApplicationContext"><a href="#4-12-刷新ApplicationContext" class="headerlink" title="4.12 刷新ApplicationContext"></a>4.12 刷新ApplicationContext</h5><p>刷新<code>BeanFactory</code></p>
<p>自定义后置处理<code>Bean</code>工厂，若未继承<code>SpringApplication</code>并且未实现该方法，未此步骤忽略</p>
<p>调用<code>Bean</code>工厂后置处理器</p>
<p>注册<code>Bean</code>后置处理器</p>
<p>初始化国际化</p>
<p>初始化应用事件</p>
<p>自定义刷新，若未继承<code>SpringApplication</code>并且未实现该方法，未此步骤忽略</p>
<p>注册所有监听到容器</p>
<p>结束<code>BeanFactory</code>初始化</p>
<p>结束<code>IOC</code>容器初始化</p>
<p>注册销毁回调</p>
<h5 id="4-13-刷新后处理"><a href="#4-13-刷新后处理" class="headerlink" title="4.13 刷新后处理"></a>4.13 刷新后处理</h5><p>回调所有Runner</p>
<h5 id="4-14-响应所有上下文初始化完成时监听"><a href="#4-14-响应所有上下文初始化完成时监听" class="headerlink" title="4.14 响应所有上下文初始化完成时监听"></a>4.14 响应所有上下文初始化完成时监听</h5><h5 id="4-15-关闭StopWatch"><a href="#4-15-关闭StopWatch" class="headerlink" title="4.15 关闭StopWatch"></a>4.15 关闭<code>StopWatch</code></h5><h5 id="4-16-日志输出"><a href="#4-16-日志输出" class="headerlink" title="4.16 日志输出"></a>4.16 日志输出</h5>
</div>
<footer class="post-footer">
<div class="post-eof"></div>
</footer>
</div>
</article>
<article class="post post-type-normal" itemscope="" itemtype="http://schema.org/Article">
<div class="post-block">
<link itemprop="mainEntityOfPage" href="https://kezhijie.org/2018/12/22/dubbo/">
<span hidden itemprop="author" itemscope="" itemtype="http://schema.org/Person">
<meta itemprop="name" content="Eightmonth | 柯志杰">
<meta itemprop="description" content="">
<meta itemprop="image" content="/images/avatar.gif">
</span>
<span hidden itemprop="publisher" itemscope="" itemtype="http://schema.org/Organization">
<meta itemprop="name" content="Eightmonth">
</span>
<header class="post-header">
<h1 class="post-title" itemprop="name headline">
<a href="/2018/12/22/dubbo/" class="post-title-link" itemprop="url">Dubbo源码架构</a>
</h1>
<div class="post-meta">
<span class="post-time">
<span class="post-meta-item-icon">
<i class="fa fa-calendar-o"></i>
</span>
<span class="post-meta-item-text">发表于</span>
<time title="创建时间：2018-12-22 12:05:20" itemprop="dateCreated datePublished" datetime="2018-12-22T12:05:20+08:00">2018-12-22</time>
</span>
<span class="post-category">
<span class="post-meta-divider">|</span>
<span class="post-meta-item-icon">
<i class="fa fa-folder-o"></i>
</span>
<span class="post-meta-item-text">分类于</span>
<span itemprop="about" itemscope="" itemtype="http://schema.org/Thing"><a href="/categories/Dubbo/" itemprop="url" rel="index"><span itemprop="name">Dubbo</span></a></span>
</span>
</div>
</header>
<div class="post-body" itemprop="articleBody">
<h1 id="Dubbo源码架构"><a href="#Dubbo源码架构" class="headerlink" title="Dubbo源码架构"></a>Dubbo源码架构</h1><blockquote>
<p>个人笔记，非原创博文 </p>
<p>最顶层概念：要么是提供方（Provider）提供服务，要么是消费方（Customer）消费服务。</p>
<p>源码地址：<a href="https://github.com/alibaba/dubbo" target="_blank" rel="noopener">https://github.com/alibaba/dubbo</a></p>
</blockquote>
<h3 id="架构抽象图"><a href="#架构抽象图" class="headerlink" title="架构抽象图"></a>架构抽象图</h3><p><img src="../../../../img/dubbo/dubbo.png" alt="dubbo架构"></p>
<h3 id="架构图一说明"><a href="#架构图一说明" class="headerlink" title="架构图一说明"></a>架构图一说明</h3><p>Dubbo框架设计一共划分了10个层，而最上面的Service层是留给实际想要使用Dubbo开发分布式服务的开发者实现业务逻辑的接口层。图中左边淡蓝背景的为服务消费方使用的接口，右边淡绿色背景的为服务提供方使用的接口， 位于中轴线上的为双方都用到的接口。</p>
<h3 id="1-业务逻辑"><a href="#1-业务逻辑" class="headerlink" title="1.业务逻辑"></a>1.业务逻辑</h3><p>服务接口层（Service）：该层是与实际业务逻辑相关的，根据服务提供方和服务消费方的业务设计对应的接口和实现。</p>
<h3 id="2-RPC模块"><a href="#2-RPC模块" class="headerlink" title="2.RPC模块"></a>2.RPC模块</h3><ul>
<li>配置层（Config）：对外配置接口，以ServiceConfig和ReferenceConfig为中心，可以直接new配置类，也可以通过spring解析配置生成配置类。</li>
</ul>
<ul>
<li>服务代理层（Proxy）：服务接口透明代理，生成服务的客户端访问入口和服务器端结构，以ServiceProxy为中心，扩展接口为ProxyFactory。</li>
</ul>
<ul>
<li>服务注册层（Registry）：封装服务地址的注册与发现，以服务URL为中心，扩展接口为RegistryFactory、Registry和RegistryService。可能没有服务注册中心，此时服务提供方直接暴露服务。</li>
</ul>
<ul>
<li>集群层（Cluster）：封装多个提供者的路由及负载均衡，并桥接注册中心，以Invoker为中心，扩展接口为Cluster、Directory、Router和LoadBalance。将多个服务提供方组合为一个服务提供方，实现对服务消费方来透明，只需要与一个服务提供方进行交互。同时这一层也是Dubbo体现服务治理的层面。</li>
</ul>
<ul>
<li>监控层（Monitor）：RPC调用次数和调用时间监控，以Statistics为中心，扩展接口为MonitorFactory、Monitor和MonitorService。</li>
<li>协议定义层（Protocol）：封将RPC调用，以Invocation和Result为中心，扩展接口为Protocol、Invoker和Exporter。Protocol是服务域，它是Invoker暴露和引用的主功能入口，它负责Invoker的生命周期管理。<strong>Invoker是实体域，它是Dubbo的核心模型，其它模型都向它靠扰，或转换成它</strong>，它代表一个可执行体，可向它发起invoke调用，它有可能是一个本地的实现，也可能是一个远程的实现，也可能一个集群实现。</li>
</ul>
<h3 id="3-远程调用协议"><a href="#3-远程调用协议" class="headerlink" title="3.远程调用协议"></a>3.远程调用协议</h3><ul>
<li>信息交换层（Exchange）：封装请求响应模式，同步转异步，以Request和Response为中心，扩展接口为Exchanger、ExchangeChannel、ExchangeClient和ExchangeServer。</li>
<li>网络传输层（Transport）：抽象mina和netty为统一接口，以Message为中心，扩展接口为Channel、Transporter、Client、Server和Codec</li>
<li>数据序列化层（Serialize）：可复用的一些工具，扩展接口为Serialization、 ObjectInput、ObjectOutput和ThreadPool。</li>
</ul>
<h2 id="额外说明"><a href="#额外说明" class="headerlink" title="额外说明"></a>额外说明</h2><p>从上图可以看出，Dubbo对于服务提供方和服务消费方，从框架的10层中分别提供了各自需要关心和扩展的接口，构建整个服务生态系统（服务提供方和服务消费方本身就是一个以服务为中心的）。</p>
<ol>
<li>在RPC中，Protocol是核心层，也就是只要有Protocol + Invoker + Exporter就可以完成非透明的RPC调用，然后在Invoker的主过程上Filter拦截点。</li>
<li>图中的Consumer和Provider是抽象概念，只是想让看图者更直观的了解哪些类分属于客户端与服务器端，不用Client和Server的原因是Dubbo在很多场景下都使用Provider、Consumer、Registry、Monitor划分逻辑拓普节点，保持统一概念。</li>
<li>Cluster是外围概念，所以Cluster的目的是将多个Invoker伪装成一个Invoker，这样其它人只要关注Protocol层Invoker即可，加上Cluster或者去掉Cluster对其它层都不会造成影响，因为只有一个提供者时，是不需要Cluster的。如果有多个提供者时，那Cluster将是Dubbo服务治理的入口，所有的服务治理都从Cluster开始并且延续到更低层的Directory、Router、LoadBalance。</li>
<li>Proxy层封装了所有接口的透明化代理，而在其它层都以Invoker为中心，只有到了暴露给用户使用时，才用Proxy将Invoker转成接口，或将接口实现转成Invoker，也就是去掉Proxy层RPC是可以Run的，只是不那么透明，不那么看起来像调本地服务一样调远程服务。</li>
<li>Remoting实现是Dubbo协议的实现，如果你选择RMI协议，整个Remoting都不会用上，Remoting内部再划为Transport传输层和Exchange信息交换层，Transport层只负责单向消息传输，是对Mina、Netty、Grizzly的抽象，它也可以扩展UDP传输，而Exchange层是在传输层之上封装了Request-Response语义。</li>
<li>Registry和Monitor实际上不算一层，而是一个独立的节点，只是为了全局概览，用层的方式画在一起。 </li>
</ol>
<h2 id="核心要点"><a href="#核心要点" class="headerlink" title="核心要点"></a>核心要点</h2><p>从上面的架构图中，我们可以了解到，Dubbo作为一个分布式服务框架，主要具有如下几个核心的要点：</p>
<h4 id="1-服务定义"><a href="#1-服务定义" class="headerlink" title="1.服务定义"></a>1.服务定义</h4><p>服务是围绕服务提供方和服务消费方的，服务提供方实现服务，而服务消费方调用服务。</p>
<h4 id="2-服务注册"><a href="#2-服务注册" class="headerlink" title="2.服务注册"></a>2.服务注册</h4><p>对于服务提供方，它需要发布服务，而且由于应用系统的复杂性，服务的数量、类型也不断膨胀；对于服务消费方，它最关心如何获取到它所需要的服务，而面对复杂的应用系统，需要管理大量的服务调用。而且，对于服务提供方和服务消费方来说，他们还有可能兼具这两种角色，即既需要提供服务，有需要消费服务。通过将服务统一管理起来，可以有效地优化内部应用对服务发布/使用的流程和管理。服务注册中心可以通过特定协议来完成服务对外的统一。Dubbo提供的注册中心有如下几种类型可供选择：</p>
<ul>
<li>Multicast注册中心</li>
<li>Zookeeper注册中心</li>
<li>Redis注册中心</li>
<li>Default注册中心</li>
</ul>
<h4 id="3-服务监控"><a href="#3-服务监控" class="headerlink" title="3.服务监控"></a>3.服务监控</h4><p>无论是服务提供方，还是服务消费方，他们都需要对服务调用的实际状态进行有效的监控，从而改进服务质量。</p>
<h4 id="4-远程通信与信息交换"><a href="#4-远程通信与信息交换" class="headerlink" title="4.远程通信与信息交换"></a>4.远程通信与信息交换</h4><p>远程通信需要指定通信双方所约定的协议，在保证通信双方理解协议语义的基础上，还要保证高效、稳定的消息传输。Dubbo继承了当前主流的网络通信框架，主要包括如下几个：</p>
<ul>
<li>Mina</li>
</ul>
<ul>
<li>Netty</li>
<li>Grizzly</li>
</ul>
<h4 id="5-服务调用"><a href="#5-服务调用" class="headerlink" title="5.服务调用"></a>5.服务调用</h4><p><img src="../../../../img/dubbo/service-call.png" alt="service-call"></p>
<blockquote>
<p>服务调用过程</p>
<p>上图中，蓝色的表示与业务有交互，绿色的表示只对Dubbo内部交互。上述图所描述的调用流程如下：</p>
<ol>
<li>服务提供方发布服务到服务注册中心；</li>
<li>服务消费方从服务注册中心订阅服务；</li>
<li>服务消费方调用已经注册的可用服务。</li>
</ol>
</blockquote>
<p>详细如图所示：</p>
<p><img src="../../../../img/dubbo/service-call-detail.png" alt="service-call-detail"></p>
<h4 id="4-服务注册与注销"><a href="#4-服务注册与注销" class="headerlink" title="4.服务注册与注销"></a>4.服务注册与注销</h4><p><img src="../../../../img/dubbo/service-register.png" alt="service-register"></p>
<h4 id="5-服务订阅与取消"><a href="#5-服务订阅与取消" class="headerlink" title="5.服务订阅与取消"></a>5.服务订阅与取消</h4><p><img src="../img/dubbo/service-Subscribe.png" alt="service-Subscribe"></p>
<h4 id="6-协议支持"><a href="#6-协议支持" class="headerlink" title="6.协议支持"></a>6.协议支持</h4><p>Dubbo支持自定义扩展协议，实现dubbo-rpc-api即可扩展出一种Dubbo支持的协议。Dubbo目前已实现的协议如下：</p>
<ul>
<li>Dubbo协议</li>
<li>Hessian协议</li>
<li>HTTP协议</li>
<li>RMI协议</li>
<li>WebService协议</li>
<li>Thrift协议</li>
<li>Memcached协议</li>
<li>Redis协议</li>
</ul>
<h2 id="Dubbo模块图"><a href="#Dubbo模块图" class="headerlink" title="Dubbo模块图"></a>Dubbo模块图</h2><p>Dubbo以包结构来组织各个模块，各个模块及其关系，如图所示：</p>
<p><img src="../../../../img/dubbo/module.png" alt="module"></p>
<ul>
<li>Dubbo-common 公共逻辑模块，包括Util类和通用模型。</li>
<li>Dubbo-remoting 远程通讯模块，相当于Dubbo协议的实现，如果RPC用RMI协议则不需要使用此包。</li>
<li>Dubbo-rpc 远程调用模块，抽象各种协议，以及动态代理，只包含一对一的调用，不关心集群的管理。</li>
<li>Dubbo-cluster 集群模块，将多个服务提供方伪装为一个提供方，包括：负载均衡、容错、路由等，集群的地址列表可以是静态配置的，也可以是由注册中心下发。</li>
<li>Dubbo-registry 注册中心模块，基于注册中心下发地址的集群方式，以及对各种注册中心的抽象。</li>
<li>Dubbo-monitor 监控模块，统计服务调用次数，调用时间的，调用链跟踪的服务。</li>
<li>Dubbo-config 配置模块，是Dubbo对外的API，用户通过Config使用Dubbo，隐藏Dubbo所有细节。</li>
<li>dubbo-container 容器模块，是一个Standalone的容器，以简单的Main加载Spring启动，因为服务通常不需要Tomcat/JBoss等Web容器的特性，没必要用Web容器去加载服务。</li>
</ul>
</div>
<footer class="post-footer">
<div class="post-eof"></div>
</footer>
</div>
</article>
<article class="post post-type-normal" itemscope="" itemtype="http://schema.org/Article">
<div class="post-block">
<link itemprop="mainEntityOfPage" href="https://kezhijie.org/2018/12/22/hello-world/">
<span hidden itemprop="author" itemscope="" itemtype="http://schema.org/Person">
<meta itemprop="name" content="Eightmonth | 柯志杰">
<meta itemprop="description" content="">
<meta itemprop="image" content="/images/avatar.gif">
</span>
<span hidden itemprop="publisher" itemscope="" itemtype="http://schema.org/Organization">
<meta itemprop="name" content="Eightmonth">
</span>
<header class="post-header">