Skip to content

Commit 51a73f9

Browse files
qq254963746qq254963746
committed
ServiceLoader 替代原来的SPI方案
1 parent 676c15e commit 51a73f9

File tree

107 files changed

+914
-2314
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

107 files changed

+914
-2314
lines changed

‎LICENSE‎

Lines changed: 191 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,191 @@
1+
Apache License
2+
Version 2.0, January 2004
3+
http://www.apache.org/licenses/
4+
5+
TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
6+
7+
1. Definitions.
8+
9+
"License" shall mean the terms and conditions for use, reproduction, and
10+
distribution as defined by Sections 1 through 9 of this document.
11+
12+
"Licensor" shall mean the copyright owner or entity authorized by the copyright
13+
owner that is granting the License.
14+
15+
"Legal Entity" shall mean the union of the acting entity and all other entities
16+
that control, are controlled by, or are under common control with that entity.
17+
For the purposes of this definition, "control" means (i) the power, direct or
18+
indirect, to cause the direction or management of such entity, whether by
19+
contract or otherwise, or (ii) ownership of fifty percent (50%) or more of the
20+
outstanding shares, or (iii) beneficial ownership of such entity.
21+
22+
"You" (or "Your") shall mean an individual or Legal Entity exercising
23+
permissions granted by this License.
24+
25+
"Source" form shall mean the preferred form for making modifications, including
26+
but not limited to software source code, documentation source, and configuration
27+
files.
28+
29+
"Object" form shall mean any form resulting from mechanical transformation or
30+
translation of a Source form, including but not limited to compiled object code,
31+
generated documentation, and conversions to other media types.
32+
33+
"Work" shall mean the work of authorship, whether in Source or Object form, made
34+
available under the License, as indicated by a copyright notice that is included
35+
in or attached to the work (an example is provided in the Appendix below).
36+
37+
"Derivative Works" shall mean any work, whether in Source or Object form, that
38+
is based on (or derived from) the Work and for which the editorial revisions,
39+
annotations, elaborations, or other modifications represent, as a whole, an
40+
original work of authorship. For the purposes of this License, Derivative Works
41+
shall not include works that remain separable from, or merely link (or bind by
42+
name) to the interfaces of, the Work and Derivative Works thereof.
43+
44+
"Contribution" shall mean any work of authorship, including the original version
45+
of the Work and any modifications or additions to that Work or Derivative Works
46+
thereof, that is intentionally submitted to Licensor for inclusion in the Work
47+
by the copyright owner or by an individual or Legal Entity authorized to submit
48+
on behalf of the copyright owner. For the purposes of this definition,
49+
"submitted" means any form of electronic, verbal, or written communication sent
50+
to the Licensor or its representatives, including but not limited to
51+
communication on electronic mailing lists, source code control systems, and
52+
issue tracking systems that are managed by, or on behalf of, the Licensor for
53+
the purpose of discussing and improving the Work, but excluding communication
54+
that is conspicuously marked or otherwise designated in writing by the copyright
55+
owner as "Not a Contribution."
56+
57+
"Contributor" shall mean Licensor and any individual or Legal Entity on behalf
58+
of whom a Contribution has been received by Licensor and subsequently
59+
incorporated within the Work.
60+
61+
2. Grant of Copyright License.
62+
63+
Subject to the terms and conditions of this License, each Contributor hereby
64+
grants to You a perpetual, worldwide, non-exclusive, no-charge, royalty-free,
65+
irrevocable copyright license to reproduce, prepare Derivative Works of,
66+
publicly display, publicly perform, sublicense, and distribute the Work and such
67+
Derivative Works in Source or Object form.
68+
69+
3. Grant of Patent License.
70+
71+
Subject to the terms and conditions of this License, each Contributor hereby
72+
grants to You a perpetual, worldwide, non-exclusive, no-charge, royalty-free,
73+
irrevocable (except as stated in this section) patent license to make, have
74+
made, use, offer to sell, sell, import, and otherwise transfer the Work, where
75+
such license applies only to those patent claims licensable by such Contributor
76+
that are necessarily infringed by their Contribution(s) alone or by combination
77+
of their Contribution(s) with the Work to which such Contribution(s) was
78+
submitted. If You institute patent litigation against any entity (including a
79+
cross-claim or counterclaim in a lawsuit) alleging that the Work or a
80+
Contribution incorporated within the Work constitutes direct or contributory
81+
patent infringement, then any patent licenses granted to You under this License
82+
for that Work shall terminate as of the date such litigation is filed.
83+
84+
4. Redistribution.
85+
86+
You may reproduce and distribute copies of the Work or Derivative Works thereof
87+
in any medium, with or without modifications, and in Source or Object form,
88+
provided that You meet the following conditions:
89+
90+
You must give any other recipients of the Work or Derivative Works a copy of
91+
this License; and
92+
You must cause any modified files to carry prominent notices stating that You
93+
changed the files; and
94+
You must retain, in the Source form of any Derivative Works that You distribute,
95+
all copyright, patent, trademark, and attribution notices from the Source form
96+
of the Work, excluding those notices that do not pertain to any part of the
97+
Derivative Works; and
98+
If the Work includes a "NOTICE" text file as part of its distribution, then any
99+
Derivative Works that You distribute must include a readable copy of the
100+
attribution notices contained within such NOTICE file, excluding those notices
101+
that do not pertain to any part of the Derivative Works, in at least one of the
102+
following places: within a NOTICE text file distributed as part of the
103+
Derivative Works; within the Source form or documentation, if provided along
104+
with the Derivative Works; or, within a display generated by the Derivative
105+
Works, if and wherever such third-party notices normally appear. The contents of
106+
the NOTICE file are for informational purposes only and do not modify the
107+
License. You may add Your own attribution notices within Derivative Works that
108+
You distribute, alongside or as an addendum to the NOTICE text from the Work,
109+
provided that such additional attribution notices cannot be construed as
110+
modifying the License.
111+
You may add Your own copyright statement to Your modifications and may provide
112+
additional or different license terms and conditions for use, reproduction, or
113+
distribution of Your modifications, or for any such Derivative Works as a whole,
114+
provided Your use, reproduction, and distribution of the Work otherwise complies
115+
with the conditions stated in this License.
116+
117+
5. Submission of Contributions.
118+
119+
Unless You explicitly state otherwise, any Contribution intentionally submitted
120+
for inclusion in the Work by You to the Licensor shall be under the terms and
121+
conditions of this License, without any additional terms or conditions.
122+
Notwithstanding the above, nothing herein shall supersede or modify the terms of
123+
any separate license agreement you may have executed with Licensor regarding
124+
such Contributions.
125+
126+
6. Trademarks.
127+
128+
This License does not grant permission to use the trade names, trademarks,
129+
service marks, or product names of the Licensor, except as required for
130+
reasonable and customary use in describing the origin of the Work and
131+
reproducing the content of the NOTICE file.
132+
133+
7. Disclaimer of Warranty.
134+
135+
Unless required by applicable law or agreed to in writing, Licensor provides the
136+
Work (and each Contributor provides its Contributions) on an "AS IS" BASIS,
137+
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied,
138+
including, without limitation, any warranties or conditions of TITLE,
139+
NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A PARTICULAR PURPOSE. You are
140+
solely responsible for determining the appropriateness of using or
141+
redistributing the Work and assume any risks associated with Your exercise of
142+
permissions under this License.
143+
144+
8. Limitation of Liability.
145+
146+
In no event and under no legal theory, whether in tort (including negligence),
147+
contract, or otherwise, unless required by applicable law (such as deliberate
148+
and grossly negligent acts) or agreed to in writing, shall any Contributor be
149+
liable to You for damages, including any direct, indirect, special, incidental,
150+
or consequential damages of any character arising as a result of this License or
151+
out of the use or inability to use the Work (including but not limited to
152+
damages for loss of goodwill, work stoppage, computer failure or malfunction, or
153+
any and all other commercial damages or losses), even if such Contributor has
154+
been advised of the possibility of such damages.
155+
156+
9. Accepting Warranty or Additional Liability.
157+
158+
While redistributing the Work or Derivative Works thereof, You may choose to
159+
offer, and charge a fee for, acceptance of support, warranty, indemnity, or
160+
other liability obligations and/or rights consistent with this License. However,
161+
in accepting such obligations, You may act only on Your own behalf and on Your
162+
sole responsibility, not on behalf of any other Contributor, and only if You
163+
agree to indemnify, defend, and hold each Contributor harmless for any liability
164+
incurred by, or claims asserted against, such Contributor by reason of your
165+
accepting any such warranty or additional liability.
166+
167+
END OF TERMS AND CONDITIONS
168+
169+
APPENDIX: How to apply the Apache License to your work
170+
171+
To apply the Apache License to your work, attach the following boilerplate
172+
notice, with the fields enclosed by brackets "[]" replaced with your own
173+
identifying information. (Don't include the brackets!) The text should be
174+
enclosed in the appropriate comment syntax for the file format. We also
175+
recommend that a file or class name and description of purpose be included on
176+
the same "printed page" as the copyright notice for easier identification within
177+
third-party archives.
178+
179+
Copyright [yyyy] [name of copyright owner]
180+
181+
Licensed under the Apache License, Version 2.0 (the "License");
182+
you may not use this file except in compliance with the License.
183+
You may obtain a copy of the License at
184+
185+
http://www.apache.org/licenses/LICENSE-2.0
186+
187+
Unless required by applicable law or agreed to in writing, software
188+
distributed under the License is distributed on an "AS IS" BASIS,
189+
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
190+
See the License for the specific language governing permissions and
191+
limitations under the License.

‎lts-admin/pom.xml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,7 @@
5656
</dependency>
5757
<dependency>
5858
<groupId>com.lts</groupId>
59-
<artifactId>lts-logger-api</artifactId>
59+
<artifactId>lts-logger</artifactId>
6060
<version>${project.version}</version>
6161
</dependency>
6262
<dependency>

‎lts-admin/src/main/java/com/lts/web/controller/api/JobQueueApiController.java‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2,9 +2,9 @@
22

33
import com.lts.biz.logger.domain.JobLogPo;
44
import com.lts.biz.logger.domain.JobLoggerRequest;
5-
import com.lts.command.Command;
6-
import com.lts.command.CommandClient;
7-
import com.lts.command.Commands;
5+
import com.lts.core.command.Command;
6+
import com.lts.core.command.CommandClient;
7+
import com.lts.core.command.Commands;
88
import com.lts.core.cluster.Node;
99
import com.lts.core.cluster.NodeType;
1010
import com.lts.core.commons.utils.Assert;

‎lts-admin/src/main/java/com/lts/web/support/spring/AdminAppFactoryBean.java‎

Lines changed: 8 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -7,10 +7,10 @@
77
import com.lts.core.commons.utils.NetUtils;
88
import com.lts.core.commons.utils.StringUtils;
99
import com.lts.core.constant.Constants;
10-
import com.lts.core.extension.ExtensionLoader;
1110
import com.lts.core.registry.RegistryStatMonitor;
11+
import com.lts.core.spi.ServiceLoader;
1212
import com.lts.core.support.SystemClock;
13-
import com.lts.ec.EventCenterFactory;
13+
import com.lts.ec.EventCenter;
1414
import com.lts.queue.*;
1515
import com.lts.web.cluster.AdminApplication;
1616
import com.lts.web.support.AppConfigurer;
@@ -24,18 +24,6 @@
2424
*/
2525
public class AdminAppFactoryBean implements FactoryBean<AdminApplication>, InitializingBean {
2626

27-
CronJobQueueFactory cronJobQueueFactory = ExtensionLoader.getExtensionLoader(
28-
CronJobQueueFactory.class).getAdaptiveExtension();
29-
ExecutableJobQueueFactory executableJobQueueFactory = ExtensionLoader.getExtensionLoader(
30-
ExecutableJobQueueFactory.class).getAdaptiveExtension();
31-
ExecutingJobQueueFactory executingJobQueueFactory = ExtensionLoader.getExtensionLoader(
32-
ExecutingJobQueueFactory.class).getAdaptiveExtension();
33-
NodeGroupStoreFactory nodeGroupStoreFactory = ExtensionLoader.getExtensionLoader(
34-
NodeGroupStoreFactory.class).getAdaptiveExtension();
35-
JobFeedbackQueueFactory jobFeedbackQueueFactory = ExtensionLoader.getExtensionLoader(
36-
JobFeedbackQueueFactory.class).getAdaptiveExtension();
37-
private EventCenterFactory eventCenterFactory = ExtensionLoader.getExtensionLoader(EventCenterFactory.class).getAdaptiveExtension();
38-
3927
private AdminApplication application;
4028

4129
@Override
@@ -84,13 +72,13 @@ public void afterPropertiesSet() throws Exception {
8472
application = new AdminApplication();
8573
application.setConfig(config);
8674
application.setNode(node);
87-
application.setJobFeedbackQueue(jobFeedbackQueueFactory.getQueue(config));
88-
application.setCronJobQueue(cronJobQueueFactory.getQueue(config));
89-
application.setExecutableJobQueue(executableJobQueueFactory.getQueue(config));
90-
application.setExecutingJobQueue(executingJobQueueFactory.getQueue(config));
91-
application.setNodeGroupStore(nodeGroupStoreFactory.getStore(config));
75+
application.setJobFeedbackQueue(ServiceLoader.load(JobFeedbackQueueFactory.class, config).getQueue(config));
76+
application.setCronJobQueue(ServiceLoader.load(CronJobQueueFactory.class, config).getQueue(config));
77+
application.setExecutableJobQueue(ServiceLoader.load(ExecutableJobQueueFactory.class, config).getQueue(config));
78+
application.setExecutingJobQueue(ServiceLoader.load(ExecutingJobQueueFactory.class, config).getQueue(config));
79+
application.setNodeGroupStore(ServiceLoader.load(NodeGroupStoreFactory.class, config).getStore(config));
9280
application.setJobLogger(new JobLoggerDelegate(config));
93-
application.setEventCenter(eventCenterFactory.getEventCenter(config));
81+
application.setEventCenter(ServiceLoader.load(EventCenter.class, config));
9482
application.setRegistryStatMonitor(new RegistryStatMonitor(application));
9583
}
9684

‎lts-core/src/main/java/com/lts/core/Application.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package com.lts.core;
22

3-
import com.lts.command.CommandCenter;
3+
import com.lts.core.command.CommandCenter;
44
import com.lts.core.cluster.Config;
55
import com.lts.core.cluster.MasterElector;
66
import com.lts.core.cluster.SubscribedNodeManager;

‎lts-core/src/main/java/com/lts/core/cluster/AbstractClientNode.java‎

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,9 +5,11 @@
55
import com.lts.core.factory.NamedThreadFactory;
66
import com.lts.core.remoting.HeartBeatMonitor;
77
import com.lts.core.remoting.RemotingClientDelegate;
8+
import com.lts.core.spi.ServiceLoader;
89
import com.lts.remoting.RemotingClient;
910
import com.lts.remoting.RemotingClientConfig;
1011
import com.lts.remoting.RemotingProcessor;
12+
import com.lts.remoting.RemotingTransporter;
1113

1214
import java.util.concurrent.Executors;
1315

@@ -74,10 +76,9 @@ protected void beforeRemotingStart() {
7476
}
7577

7678
private RemotingClient getRemotingClient(RemotingClientConfig remotingClientConfig) {
77-
return remotingTransporter.getRemotingClient(config, remotingClientConfig);
79+
return ServiceLoader.load(RemotingTransporter.class, config).getRemotingClient(remotingClientConfig);
7880
}
7981

80-
8182
@Override
8283
protected void afterRemotingStart() {
8384
// 父类要做的

‎lts-core/src/main/java/com/lts/core/cluster/AbstractJobNode.java‎

Lines changed: 3 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -4,9 +4,7 @@
44
import com.lts.core.commons.utils.CollectionUtils;
55
import com.lts.core.commons.utils.GenericsUtils;
66
import com.lts.core.commons.utils.StringUtils;
7-
import com.lts.core.compiler.support.AdaptiveCompiler;
87
import com.lts.core.constant.Constants;
9-
import com.lts.core.extension.ExtensionLoader;
108
import com.lts.core.factory.JobNodeConfigFactory;
119
import com.lts.core.factory.NodeFactory;
1210
import com.lts.core.listener.MasterChangeListener;
@@ -17,8 +15,8 @@
1715
import com.lts.core.logger.LoggerFactory;
1816
import com.lts.core.protocol.command.CommandBodyWrapper;
1917
import com.lts.core.registry.*;
20-
import com.lts.ec.EventCenterFactory;
21-
import com.lts.remoting.RemotingTransporter;
18+
import com.lts.core.spi.ServiceLoader;
19+
import com.lts.ec.EventCenter;
2220
import com.lts.remoting.serialize.AdaptiveSerializable;
2321

2422
import java.util.ArrayList;
@@ -39,10 +37,6 @@ public abstract class AbstractJobNode<T extends Node, App extends Application> i
3937
protected App application;
4038
private List<NodeChangeListener> nodeChangeListeners;
4139
private List<MasterChangeListener> masterChangeListeners;
42-
private EventCenterFactory eventCenterFactory = ExtensionLoader
43-
.getExtensionLoader(EventCenterFactory.class).getAdaptiveExtension();
44-
protected RemotingTransporter remotingTransporter = ExtensionLoader
45-
.getExtensionLoader(RemotingTransporter.class).getAdaptiveExtension();
4640
private AtomicBoolean started = new AtomicBoolean(false);
4741

4842
public AbstractJobNode() {
@@ -112,7 +106,7 @@ public void destroy() {
112106
}
113107

114108
protected void initConfig() {
115-
application.setEventCenter(eventCenterFactory.getEventCenter(config));
109+
application.setEventCenter(ServiceLoader.load(EventCenter.class, config));
116110

117111
application.setCommandBodyWrapper(new CommandBodyWrapper(config));
118112
application.setMasterElector(new MasterElector(application));
@@ -142,12 +136,6 @@ private void setSpiConfig() {
142136
if (StringUtils.isNotEmpty(defaultSerializable)) {
143137
AdaptiveSerializable.setDefaultSerializable(defaultSerializable);
144138
}
145-
146-
// 设置编译器
147-
String compiler = config.getParameter(Constants.COMPILER);
148-
if (StringUtils.isNotEmpty(compiler)) {
149-
AdaptiveCompiler.setDefaultCompiler(compiler);
150-
}
151139
}
152140

153141
private void initRegistry() {

‎lts-core/src/main/java/com/lts/core/cluster/AbstractServerNode.java‎

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,9 +4,11 @@
44
import com.lts.core.constant.Constants;
55
import com.lts.core.factory.NamedThreadFactory;
66
import com.lts.core.remoting.RemotingServerDelegate;
7+
import com.lts.core.spi.ServiceLoader;
78
import com.lts.remoting.RemotingProcessor;
89
import com.lts.remoting.RemotingServer;
910
import com.lts.remoting.RemotingServerConfig;
11+
import com.lts.remoting.RemotingTransporter;
1012

1113
import java.util.concurrent.Executors;
1214

@@ -54,7 +56,7 @@ protected void beforeRemotingStart() {
5456
}
5557

5658
private RemotingServer getRemotingServer(RemotingServerConfig remotingServerConfig) {
57-
return remotingTransporter.getRemotingServer(config, remotingServerConfig);
59+
return ServiceLoader.load(RemotingTransporter.class, config).getRemotingServer(remotingServerConfig);
5860
}
5961

6062
@Override

lts-core/src/main/java/com/lts/command/Command.java renamed to lts-core/src/main/java/com/lts/core/command/Command.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.lts.command;
1+
package com.lts.core.command;
22

33
import java.io.BufferedReader;
44
import java.io.IOException;

lts-core/src/main/java/com/lts/command/CommandCenter.java renamed to lts-core/src/main/java/com/lts/core/command/CommandCenter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.lts.command;
1+
package com.lts.core.command;
22

33
import com.lts.core.cluster.Config;
44
import com.lts.core.commons.utils.StringUtils;

0 commit comments

Comments
 (0)