Skip to content

Commit

Permalink
Merge pull request #423 from xxxxzr/fix/basicService
Browse files Browse the repository at this point in the history
Fix/basic service
  • Loading branch information
rayzhang0603 committed Apr 26, 2017
2 parents 8f71849 + 4a05c51 commit 7ea6829
Show file tree
Hide file tree
Showing 4 changed files with 20 additions and 20 deletions.
Empty file added docs/wiki/en_userguide.md
Empty file.
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@ public class ServiceConfig<T> extends AbstractServiceConfig {
// service 对应的exporters,用于管理service服务的生命周期
private List<Exporter<T>> exporters = new CopyOnWriteArrayList<Exporter<T>>();
private Class<T> interfaceClass;
private BasicServiceInterfaceConfig basicServiceConfig;
private BasicServiceInterfaceConfig basicService;
private AtomicBoolean exported = new AtomicBoolean(false);
// service的用于注册的url,用于管理service注册的生命周期,url为regitry url,内部嵌套service url。
private ConcurrentHashSet<URL> registereUrls = new ConcurrentHashSet<URL>();
Expand Down Expand Up @@ -153,8 +153,8 @@ private void doExport(ProtocolConfig protocolConfig, int port, List<URL> registr
}

String hostAddress = host;
if (StringUtils.isBlank(hostAddress) && basicServiceConfig != null) {
hostAddress = basicServiceConfig.getHost();
if (StringUtils.isBlank(hostAddress) && basicService != null) {
hostAddress = basicService.getHost();
}
if (NetUtils.isInvalidLocalHost(hostAddress)) {
hostAddress = getLocalHostAddress(registryURLs);
Expand All @@ -165,7 +165,7 @@ private void doExport(ProtocolConfig protocolConfig, int port, List<URL> registr
map.put(URLParamType.nodeType.getName(), MotanConstants.NODE_TYPE_SERVICE);
map.put(URLParamType.refreshTimestamp.getName(), String.valueOf(System.currentTimeMillis()));

collectConfigParams(map, protocolConfig, basicServiceConfig, extConfig, this);
collectConfigParams(map, protocolConfig, basicService, extConfig, this);
collectMethodConfigParams(map, this.getMethods());

URL serviceUrl = new URL(protocolName, hostAddress, port, interfaceClass.getName(), map);
Expand Down Expand Up @@ -231,12 +231,12 @@ private void afterUnexport() {
}

@ConfigDesc(excluded = true)
public BasicServiceInterfaceConfig getBasicServiceConfig() {
return basicServiceConfig;
public BasicServiceInterfaceConfig getBasicService() {
return basicService;
}

public void setBasicServiceConfig(BasicServiceInterfaceConfig basicServiceConfig) {
this.basicServiceConfig = basicServiceConfig;
public void setBasicService(BasicServiceInterfaceConfig basicService) {
this.basicService = basicService;
}

public Map<String, Integer> getProtocolAndPort() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -202,7 +202,7 @@ public Object postProcessAfterInitialization(Object bean, String beanName) throw
serviceConfig.setBeanFactory(beanFactory);

if (service.basicService() != null && service.basicService().length() > 0) {
serviceConfig.setBasicServiceConfig(beanFactory.getBean(service.basicService(), BasicServiceInterfaceConfig.class));
serviceConfig.setBasicService(beanFactory.getBean(service.basicService(), BasicServiceInterfaceConfig.class));
}

if (service.export() != null && service.export().length() > 0) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -100,7 +100,7 @@ public void onApplicationEvent(ContextRefreshedEvent event) {
* 检查并配置basicConfig
*/
private void checkAndConfigBasicConfig() {
if (getBasicServiceConfig() == null) {
if (getBasicService() == null) {
if (MotanNamespaceHandler.basicServiceConfigDefineNames.size() == 0) {
if (beanFactory instanceof ListableBeanFactory) {
ListableBeanFactory listableBeanFactory = (ListableBeanFactory) beanFactory;
Expand All @@ -116,9 +116,9 @@ private void checkAndConfigBasicConfig() {
continue;
}
if (MotanNamespaceHandler.basicServiceConfigDefineNames.size() == 1) {
setBasicServiceConfig(biConfig);
setBasicService(biConfig);
} else if (biConfig.isDefault() != null && biConfig.isDefault().booleanValue()) {
setBasicServiceConfig(biConfig);
setBasicService(biConfig);
}
}
}
Expand All @@ -128,11 +128,11 @@ private void checkAndConfigBasicConfig() {
* 检查是否已经装配export,如果没有则到basicConfig查找
*/
private void checkAndConfigExport() {
if (StringUtils.isBlank(getExport()) && getBasicServiceConfig() != null
&& !StringUtils.isBlank(getBasicServiceConfig().getExport())) {
setExport(getBasicServiceConfig().getExport());
if (getBasicServiceConfig().getProtocols() != null) {
setProtocols(new ArrayList<ProtocolConfig>(getBasicServiceConfig().getProtocols()));
if (StringUtils.isBlank(getExport()) && getBasicService() != null
&& !StringUtils.isBlank(getBasicService().getExport())) {
setExport(getBasicService().getExport());
if (getBasicService().getProtocols() != null) {
setProtocols(new ArrayList<ProtocolConfig>(getBasicService().getProtocols()));
}
}

Expand Down Expand Up @@ -169,9 +169,9 @@ private void checkAndConfigExport() {
* 检查并配置registry
*/
private void checkAndConfigRegistry() {
if (CollectionUtil.isEmpty(getRegistries()) && getBasicServiceConfig() != null
&& !CollectionUtil.isEmpty(getBasicServiceConfig().getRegistries())) {
setRegistries(getBasicServiceConfig().getRegistries());
if (CollectionUtil.isEmpty(getRegistries()) && getBasicService() != null
&& !CollectionUtil.isEmpty(getBasicService().getRegistries())) {
setRegistries(getBasicService().getRegistries());
}
if (CollectionUtil.isEmpty(getRegistries())) {
for (String name : MotanNamespaceHandler.registryDefineNames) {
Expand Down

0 comments on commit 7ea6829

Please sign in to comment.