Commit d3963485 by Nepxion

为listener增加优先级机制

parent 9444f64a
...@@ -24,4 +24,9 @@ public class BasicListener implements Listener { ...@@ -24,4 +24,9 @@ public class BasicListener implements Listener {
@Autowired @Autowired
protected PluginEventWapper pluginEventWapper; protected PluginEventWapper pluginEventWapper;
@Override
public int getOrder() {
return 0;
}
} }
\ No newline at end of file
...@@ -9,6 +9,8 @@ package com.nepxion.discovery.plugin.framework.listener; ...@@ -9,6 +9,8 @@ package com.nepxion.discovery.plugin.framework.listener;
* @version 1.0 * @version 1.0
*/ */
public interface Listener { import org.springframework.core.Ordered;
public interface Listener extends Ordered {
} }
\ No newline at end of file
...@@ -11,20 +11,14 @@ package com.nepxion.discovery.plugin.framework.listener.discovery; ...@@ -11,20 +11,14 @@ package com.nepxion.discovery.plugin.framework.listener.discovery;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.discovery.DiscoveryClient; import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.core.Ordered;
import com.nepxion.discovery.plugin.framework.listener.BasicListener; import com.nepxion.discovery.plugin.framework.listener.BasicListener;
public abstract class AbstractDiscoveryListener extends BasicListener implements DiscoveryListener, Ordered { public abstract class AbstractDiscoveryListener extends BasicListener implements DiscoveryListener {
@Autowired @Autowired
protected DiscoveryClient discoveryClient; protected DiscoveryClient discoveryClient;
public DiscoveryClient getDiscoveryClient() { public DiscoveryClient getDiscoveryClient() {
return discoveryClient; return discoveryClient;
} }
@Override
public int getOrder() {
return 0;
}
} }
\ No newline at end of file
...@@ -16,7 +16,6 @@ import java.util.Map; ...@@ -16,7 +16,6 @@ import java.util.Map;
import org.apache.commons.collections4.CollectionUtils; import org.apache.commons.collections4.CollectionUtils;
import org.springframework.cloud.client.ServiceInstance; import org.springframework.cloud.client.ServiceInstance;
import org.springframework.core.Ordered;
import com.nepxion.discovery.common.entity.DiscoveryEntity; import com.nepxion.discovery.common.entity.DiscoveryEntity;
import com.nepxion.discovery.common.entity.FilterType; import com.nepxion.discovery.common.entity.FilterType;
...@@ -113,6 +112,6 @@ public class HostFilterDiscoveryListener extends AbstractDiscoveryListener { ...@@ -113,6 +112,6 @@ public class HostFilterDiscoveryListener extends AbstractDiscoveryListener {
@Override @Override
public int getOrder() { public int getOrder() {
// Highest priority // Highest priority
return Ordered.HIGHEST_PRECEDENCE; return HIGHEST_PRECEDENCE;
} }
} }
\ No newline at end of file
...@@ -18,7 +18,6 @@ import org.apache.commons.collections4.CollectionUtils; ...@@ -18,7 +18,6 @@ import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.collections4.MapUtils; import org.apache.commons.collections4.MapUtils;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.springframework.cloud.client.ServiceInstance; import org.springframework.cloud.client.ServiceInstance;
import org.springframework.core.Ordered;
import com.nepxion.discovery.common.constant.DiscoveryConstant; import com.nepxion.discovery.common.constant.DiscoveryConstant;
import com.nepxion.discovery.common.entity.DiscoveryEntity; import com.nepxion.discovery.common.entity.DiscoveryEntity;
...@@ -130,6 +129,6 @@ public class VersionFilterDiscoveryListener extends AbstractDiscoveryListener { ...@@ -130,6 +129,6 @@ public class VersionFilterDiscoveryListener extends AbstractDiscoveryListener {
@Override @Override
public int getOrder() { public int getOrder() {
// After host filter // After host filter
return Ordered.HIGHEST_PRECEDENCE + 1; return HIGHEST_PRECEDENCE + 1;
} }
} }
\ No newline at end of file
...@@ -9,13 +9,8 @@ package com.nepxion.discovery.plugin.framework.listener.loadbalance; ...@@ -9,13 +9,8 @@ package com.nepxion.discovery.plugin.framework.listener.loadbalance;
* @version 1.0 * @version 1.0
*/ */
import org.springframework.core.Ordered;
import com.nepxion.discovery.plugin.framework.listener.BasicListener; import com.nepxion.discovery.plugin.framework.listener.BasicListener;
public abstract class AbstractLoadBalanceListener extends BasicListener implements LoadBalanceListener, Ordered { public abstract class AbstractLoadBalanceListener extends BasicListener implements LoadBalanceListener {
@Override
public int getOrder() {
return 0;
}
} }
\ No newline at end of file
...@@ -15,7 +15,6 @@ import java.util.List; ...@@ -15,7 +15,6 @@ import java.util.List;
import java.util.Map; import java.util.Map;
import org.apache.commons.collections4.CollectionUtils; import org.apache.commons.collections4.CollectionUtils;
import org.springframework.core.Ordered;
import com.nepxion.discovery.common.entity.DiscoveryEntity; import com.nepxion.discovery.common.entity.DiscoveryEntity;
import com.nepxion.discovery.common.entity.FilterType; import com.nepxion.discovery.common.entity.FilterType;
...@@ -108,6 +107,6 @@ public class HostFilterLoadBalanceListener extends AbstractLoadBalanceListener { ...@@ -108,6 +107,6 @@ public class HostFilterLoadBalanceListener extends AbstractLoadBalanceListener {
@Override @Override
public int getOrder() { public int getOrder() {
// Highest priority // Highest priority
return Ordered.HIGHEST_PRECEDENCE; return HIGHEST_PRECEDENCE;
} }
} }
\ No newline at end of file
...@@ -17,7 +17,6 @@ import java.util.Map; ...@@ -17,7 +17,6 @@ import java.util.Map;
import org.apache.commons.collections4.CollectionUtils; import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.collections4.MapUtils; import org.apache.commons.collections4.MapUtils;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.springframework.core.Ordered;
import com.nepxion.discovery.common.entity.DiscoveryEntity; import com.nepxion.discovery.common.entity.DiscoveryEntity;
import com.nepxion.discovery.common.entity.RuleEntity; import com.nepxion.discovery.common.entity.RuleEntity;
...@@ -124,6 +123,6 @@ public class VersionFilterLoadBalanceListener extends AbstractLoadBalanceListene ...@@ -124,6 +123,6 @@ public class VersionFilterLoadBalanceListener extends AbstractLoadBalanceListene
@Override @Override
public int getOrder() { public int getOrder() {
// After host filter // After host filter
return Ordered.HIGHEST_PRECEDENCE + 1; return HIGHEST_PRECEDENCE + 1;
} }
} }
\ No newline at end of file
...@@ -11,20 +11,14 @@ package com.nepxion.discovery.plugin.framework.listener.register; ...@@ -11,20 +11,14 @@ package com.nepxion.discovery.plugin.framework.listener.register;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.serviceregistry.ServiceRegistry; import org.springframework.cloud.client.serviceregistry.ServiceRegistry;
import org.springframework.core.Ordered;
import com.nepxion.discovery.plugin.framework.listener.BasicListener; import com.nepxion.discovery.plugin.framework.listener.BasicListener;
public abstract class AbstractRegisterListener extends BasicListener implements RegisterListener, Ordered { public abstract class AbstractRegisterListener extends BasicListener implements RegisterListener {
@Autowired @Autowired
protected ServiceRegistry<?> serviceRegistry; protected ServiceRegistry<?> serviceRegistry;
public ServiceRegistry<?> getServiceRegistry() { public ServiceRegistry<?> getServiceRegistry() {
return serviceRegistry; return serviceRegistry;
} }
@Override
public int getOrder() {
return 0;
}
} }
\ No newline at end of file
...@@ -13,7 +13,6 @@ import java.util.Map; ...@@ -13,7 +13,6 @@ import java.util.Map;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.serviceregistry.Registration; import org.springframework.cloud.client.serviceregistry.Registration;
import org.springframework.core.Ordered;
import com.nepxion.discovery.common.constant.DiscoveryConstant; import com.nepxion.discovery.common.constant.DiscoveryConstant;
import com.nepxion.discovery.common.entity.CountFilterEntity; import com.nepxion.discovery.common.entity.CountFilterEntity;
...@@ -100,6 +99,6 @@ public class CountFilterRegisterListener extends AbstractRegisterListener { ...@@ -100,6 +99,6 @@ public class CountFilterRegisterListener extends AbstractRegisterListener {
@Override @Override
public int getOrder() { public int getOrder() {
// Before host filter // Before host filter
return Ordered.LOWEST_PRECEDENCE - 1; return LOWEST_PRECEDENCE - 1;
} }
} }
\ No newline at end of file
...@@ -15,7 +15,6 @@ import java.util.Map; ...@@ -15,7 +15,6 @@ import java.util.Map;
import org.apache.commons.collections4.CollectionUtils; import org.apache.commons.collections4.CollectionUtils;
import org.springframework.cloud.client.serviceregistry.Registration; import org.springframework.cloud.client.serviceregistry.Registration;
import org.springframework.core.Ordered;
import com.nepxion.discovery.common.entity.FilterType; import com.nepxion.discovery.common.entity.FilterType;
import com.nepxion.discovery.common.entity.HostFilterEntity; import com.nepxion.discovery.common.entity.HostFilterEntity;
...@@ -127,6 +126,6 @@ public class HostFilterRegisterListener extends AbstractRegisterListener { ...@@ -127,6 +126,6 @@ public class HostFilterRegisterListener extends AbstractRegisterListener {
@Override @Override
public int getOrder() { public int getOrder() {
// Lowest priority // Lowest priority
return Ordered.LOWEST_PRECEDENCE; return LOWEST_PRECEDENCE;
} }
} }
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment