Skip to content

Commit

Permalink
[alibaba#5985] Fix unit tests in nacos-core
Browse files Browse the repository at this point in the history
  • Loading branch information
realJackSun committed Jun 16, 2021
1 parent 95d608a commit d92068c
Show file tree
Hide file tree
Showing 3 changed files with 211 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -152,6 +152,7 @@ public void testMemberOnFailWhenReachMaxFailAccessCnt() {
final Member search3 = memberManager.find(remote.getAddress());
Assert.assertEquals(0, search3.getFailAccessCnt());
Assert.assertEquals(NodeState.UP, search3.getState());
memberManager.memberLeave(Collections.singletonList(remote));
}

@Test
Expand All @@ -170,6 +171,7 @@ public void testMemberOnFailWhenConnectRefused() {
final Member search2 = memberManager.find(remote.getAddress());
Assert.assertEquals(0, search2.getFailAccessCnt());
Assert.assertEquals(NodeState.UP, search2.getState());
memberManager.memberLeave(Collections.singletonList(remote));
}

@Test
Expand Down Expand Up @@ -208,6 +210,7 @@ public void onEvent(MembersChangeEvent event) {
.findFirst().orElseThrow(() -> new AssertionError("member is null"));
Assert.assertEquals(0, member2.getFailAccessCnt());
Assert.assertEquals(NodeState.UP, member2.getState());
memberManager.memberLeave(Collections.singletonList(remote));
}

@Test
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -26,37 +26,46 @@
import java.util.Random;
import java.util.concurrent.TimeUnit;

import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertTrue;

public class TpsMonitorManagerTester {

static TpsMonitorManager tpsMonitorManager = new TpsMonitorManager();

private static final int MAX_COUNT1 = 5000;

private static final int MAX_COUNT2 = 2000000;

static {
TpsMonitorPoint publish = new TpsMonitorPoint("configPublish");
tpsMonitorManager.registerTpsControlPoint(publish);
TpsControlRule rule = new TpsControlRule();
rule.setPointRule(new TpsControlRule.Rule(5000, TimeUnit.SECONDS, "SUM", "intercept"));
rule.setPointRule(new TpsControlRule.Rule(MAX_COUNT1, TimeUnit.SECONDS, "SUM", "intercept"));
rule.getMonitorKeyRule()
.putIfAbsent("testKey:a*b", new TpsControlRule.Rule(5000, TimeUnit.MINUTES, "EACH", "intercept"));
.putIfAbsent("testKey:a*b", new TpsControlRule.Rule(MAX_COUNT1, TimeUnit.MINUTES, "EACH", "intercept"));
rule.getMonitorKeyRule()
.putIfAbsent("testKey:*", new TpsControlRule.Rule(2000000, TimeUnit.MINUTES, "SUM", "intercept"));
.putIfAbsent("testKey:*", new TpsControlRule.Rule(MAX_COUNT2, TimeUnit.MINUTES, "SUM", "intercept"));

publish.applyRule(rule);
}

@Test
public void test() {
for (int i = 0; i < 10000000; i++) {
for (int i = 0; i < 10000; i++) {
String value = "atg" + (new Random().nextInt(100) + 2) + "efb";
boolean pass = tpsMonitorManager
.applyTps("configPublish", "testconnectionId", Lists.list(new TestKey(value)));
try {
if (i < MAX_COUNT1) {
assertTrue(pass);
} else {
assertFalse(pass);
}
Thread.sleep(1L);
} catch (InterruptedException e) {
e.printStackTrace();
}
if (!pass) {
System.out.println("Apply tps fail.");
}
}
}

Expand Down
192 changes: 192 additions & 0 deletions core/src/test/resources/application.properties
Original file line number Diff line number Diff line change
@@ -0,0 +1,192 @@
#
# Copyright 1999-2018 Alibaba Group Holding Ltd.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#

#*************** Spring Boot Related Configurations ***************#
### Default web context path:
server.servlet.contextPath=/nacos
### Default web server port:

#*************** Network Related Configurations ***************#
### If prefer hostname over ip for Nacos server addresses in cluster.conf:
# nacos.inetutils.prefer-hostname-over-ip=false

### Specify local server's IP:
# nacos.inetutils.ip-address=


#*************** Config Module Related Configurations ***************#
### If use MySQL as datasource:
# spring.datasource.platform=mysql

### Count of DB:
# db.num=1

### Connect URL of DB:
# db.url.0=jdbc:mysql://127.0.0.1:3306/nacos?characterEncoding=utf8&connectTimeout=1000&socketTimeout=3000&autoReconnect=true&useUnicode=true&useSSL=false&serverTimezone=UTC
# db.user.0=nacos
# db.password.0=nacos

#*************** Naming Module Related Configurations ***************#
### Data dispatch task execution period in milliseconds:
# nacos.naming.distro.taskDispatchPeriod=200

### Data count of batch sync task:
# nacos.naming.distro.batchSyncKeyCount=1000

### Retry delay in milliseconds if sync task failed:
# nacos.naming.distro.syncRetryDelay=5000

### If enable data warmup. If set to false, the server would accept request without local data preparation:
# nacos.naming.data.warmup=true

### If enable the instance auto expiration, kind like of health check of instance:
# nacos.naming.expireInstance=true

nacos.naming.empty-service.auto-clean=true
nacos.naming.empty-service.clean.initial-delay-ms=50000
nacos.naming.empty-service.clean.period-time-ms=30000


#*************** CMDB Module Related Configurations ***************#
### The interval to dump external CMDB in seconds:
# nacos.cmdb.dumpTaskInterval=3600

### The interval of polling data change event in seconds:
# nacos.cmdb.eventTaskInterval=10

### The interval of loading labels in seconds:
# nacos.cmdb.labelTaskInterval=300

### If turn on data loading task:
# nacos.cmdb.loadDataAtStart=false


#*************** Metrics Related Configurations ***************#
### Metrics for prometheus
management.endpoints.web.exposure.include=*

### Metrics for elastic search
management.metrics.export.elastic.enabled=false
#management.metrics.export.elastic.host=http://localhost:9200

### Metrics for influx
management.metrics.export.influx.enabled=false
#management.metrics.export.influx.db=springboot
#management.metrics.export.influx.uri=http://localhost:8086
#management.metrics.export.influx.auto-create-db=true
#management.metrics.export.influx.consistency=one
#management.metrics.export.influx.compressed=true

#*************** Access Log Related Configurations ***************#
### If turn on the access log:
server.tomcat.accesslog.enabled=true

### accesslog automatic cleaning time
server.tomcat.accesslog.max-days=30

### The access log pattern:
server.tomcat.accesslog.pattern=%h %l %u %t "%r" %s %b %D %{User-Agent}i %{Request-Source}i

### The directory of access log:
server.tomcat.basedir=
#spring.datasource.platform=mysql
#db.num=1
#db.url.0=jdbc:mysql://10.101.167.27:3306/acm?characterEncoding=utf8&connectTimeout=1000&socketTimeout=10000&autoReconnect=true
#db.user=root
#db.password=root
#*************** Access Control Related Configurations ***************#
### If enable spring security, this option is deprecated in 1.2.0:
#spring.security.enabled=false

### The ignore urls of auth, is deprecated in 1.2.0:
nacos.security.ignore.urls=/,/error,/**/*.css,/**/*.js,/**/*.html,/**/*.map,/**/*.svg,/**/*.png,/**/*.ico,/console-ui/public/**,/v1/auth/**,/v1/console/health/**,/actuator/**,/v1/console/server/**

### The auth system to use, currently only 'nacos' and 'ldap' is supported:
nacos.core.auth.system.type=nacos

### If turn on auth system:
nacos.core.auth.enabled=false

### worked when nacos.core.auth.system.type=ldap,{0} is Placeholder,replace login username
# nacos.core.auth.ldap.url=ldap://localhost:389
# nacos.core.auth.ldap.userdn=cn={0},ou=user,dc=company,dc=com

### The token expiration in seconds:
nacos.core.auth.default.token.expire.seconds=18000

### The default token:
nacos.core.auth.default.token.secret.key=SecretKey012345678901234567890123456789012345678901234567890123456789

### Turn on/off caching of auth information. By turning on this switch, the update of auth information would have a 15 seconds delay.
nacos.core.auth.caching.enabled=true

### Since 1.4.1, Turn on/off white auth for user-agent: nacos-server, only for upgrade from old version.
nacos.core.auth.enable.userAgentAuthWhite=false

### Since 1.4.1, worked when nacos.core.auth.enabled=true and nacos.core.auth.enable.userAgentAuthWhite=false.
### The two properties is the white list for auth and used by identity the request from other server.
nacos.core.auth.server.identity.key=serverIdentity
nacos.core.auth.server.identity.value=security

#*************** Istio Related Configurations ***************#
### If turn on the MCP server:
nacos.istio.mcp.server.enabled=false



###*************** Add from 1.3.0 ***************###


#*************** Core Related Configurations ***************#

### set the WorkerID manually
# nacos.core.snowflake.worker-id=

### Member-MetaData
# nacos.core.member.meta.site=
# nacos.core.member.meta.adweight=
# nacos.core.member.meta.weight=

### MemberLookup
### Addressing pattern category, If set, the priority is highest
# nacos.core.member.lookup.type=[file,address-server]
## Set the cluster list with a configuration file or command-line argument
# nacos.member.list=192.168.16.101:8847?raft_port=8807,192.168.16.101?raft_port=8808,192.168.16.101:8849?raft_port=8809
## for AddressServerMemberLookup
# Maximum number of retries to query the address server upon initialization
# nacos.core.address-server.retry=5
## Server domain name address of [address-server] mode
# address.server.domain=jmenv.tbsite.net
## Server port of [address-server] mode
# address.server.port=8080
## Request address of [address-server] mode
# address.server.url=/nacos/serverlist

#*************** JRaft Related Configurations ***************#

### Sets the Raft cluster election timeout, default value is 5 second
# nacos.core.protocol.raft.data.election_timeout_ms=5000
### Sets the amount of time the Raft snapshot will execute periodically, default is 30 minute
# nacos.core.protocol.raft.data.snapshot_interval_secs=30
### raft internal worker threads
# nacos.core.protocol.raft.data.core_thread_num=8
### Number of threads required for raft business request processing
# nacos.core.protocol.raft.data.cli_service_thread_num=4
### raft linear read strategy. Safe linear reads are used by default, that is, the Leader tenure is confirmed by heartbeat
# nacos.core.protocol.raft.data.read_index_type=ReadOnlySafe
### rpc request timeout, default 5 seconds
# nacos.core.protocol.raft.data.rpc_request_timeout_ms=5000

0 comments on commit d92068c

Please sign in to comment.