fizzgate/fizz-gateway-node
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update Nacos by using the Spring cloud version

Browse Source
This commit is contained in:
zhongjie
2021-06-08 16:13:20 +08:00
parent 3282bae017
commit 2807972dbf
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
fizz-core/src/main/java/we/proxy/NacosUriSelector.java
View File

@@ -1,7 +1,7 @@
package we.proxy;
import com.alibaba.cloud.nacos.NacosDiscoveryProperties;
import com.alibaba.nacos.api.annotation.NacosInjected;
import com.alibaba.cloud.nacos.NacosServiceManager;
import com.alibaba.nacos.api.exception.NacosException;
import com.alibaba.nacos.api.naming.NamingService;
import com.alibaba.nacos.api.naming.pojo.Instance;
@@ -25,11 +25,12 @@ import java.util.List;
public class NacosUriSelector extends AbstractDiscoveryClientUriSelector {
private static final Logger log = LoggerFactory.getLogger(NacosUriSelector.class);
public NacosUriSelector(NacosDiscoveryProperties discoveryProperties) {
public NacosUriSelector(NacosServiceManager nacosServiceManager, NacosDiscoveryProperties discoveryProperties) {
this.nacosServiceManager = nacosServiceManager;
this.discoveryProperties = discoveryProperties;
}
@NacosInjected
final private NacosServiceManager nacosServiceManager;
private NamingService naming;
final private NacosDiscoveryProperties discoveryProperties;
private String groupName;
@@ -39,6 +40,7 @@ public class NacosUriSelector extends AbstractDiscoveryClientUriSelector {
@PostConstruct
public void init() {
naming = nacosServiceManager.getNamingService(discoveryProperties.getNacosProperties());
this.groupName = discoveryProperties.getGroup();
if (StringUtils.hasText(groupName)) {
this.useGroupName = true;