Skip to content

Commit 6603747

Browse files
author
lichengsheng
committed
添加测试用例
1 parent 172ff72 commit 6603747

23 files changed

+4096
-0
lines changed

‎mq-client/mq-client-core/src/test/java/com/ppdai/infrastructure/mq/client/AbstractMockResource.java‎

Lines changed: 155 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,155 @@
1+
package com.ppdai.infrastructure.mq.client;
2+
3+
import java.util.List;
4+
5+
import com.ppdai.infrastructure.mq.biz.dto.client.CatRequest;
6+
import com.ppdai.infrastructure.mq.biz.dto.client.CommitOffsetRequest;
7+
import com.ppdai.infrastructure.mq.biz.dto.client.ConsumerDeRegisterRequest;
8+
import com.ppdai.infrastructure.mq.biz.dto.client.ConsumerGroupRegisterRequest;
9+
import com.ppdai.infrastructure.mq.biz.dto.client.ConsumerGroupRegisterResponse;
10+
import com.ppdai.infrastructure.mq.biz.dto.client.ConsumerRegisterRequest;
11+
import com.ppdai.infrastructure.mq.biz.dto.client.FailMsgPublishAndUpdateResultRequest;
12+
import com.ppdai.infrastructure.mq.biz.dto.client.GetConsumerGroupRequest;
13+
import com.ppdai.infrastructure.mq.biz.dto.client.GetConsumerGroupResponse;
14+
import com.ppdai.infrastructure.mq.biz.dto.client.GetGroupTopicRequest;
15+
import com.ppdai.infrastructure.mq.biz.dto.client.GetGroupTopicResponse;
16+
import com.ppdai.infrastructure.mq.biz.dto.client.GetMessageCountRequest;
17+
import com.ppdai.infrastructure.mq.biz.dto.client.GetMessageCountResponse;
18+
import com.ppdai.infrastructure.mq.biz.dto.client.GetMetaGroupRequest;
19+
import com.ppdai.infrastructure.mq.biz.dto.client.GetMetaGroupResponse;
20+
import com.ppdai.infrastructure.mq.biz.dto.client.GetTopicQueueIdsRequest;
21+
import com.ppdai.infrastructure.mq.biz.dto.client.GetTopicQueueIdsResponse;
22+
import com.ppdai.infrastructure.mq.biz.dto.client.GetTopicRequest;
23+
import com.ppdai.infrastructure.mq.biz.dto.client.GetTopicResponse;
24+
import com.ppdai.infrastructure.mq.biz.dto.client.HeartbeatRequest;
25+
import com.ppdai.infrastructure.mq.biz.dto.client.LogRequest;
26+
import com.ppdai.infrastructure.mq.biz.dto.client.OpLogRequest;
27+
import com.ppdai.infrastructure.mq.biz.dto.client.PublishMessageRequest;
28+
import com.ppdai.infrastructure.mq.biz.dto.client.PullDataRequest;
29+
import com.ppdai.infrastructure.mq.biz.dto.client.PullDataResponse;
30+
import com.ppdai.infrastructure.mq.biz.dto.client.SendMailRequest;
31+
import com.ppdai.infrastructure.mq.client.resource.IMqResource;
32+
33+
public abstract class AbstractMockResource implements IMqResource{
34+
35+
@Override
36+
public void setUrls(List<String> urlsTempG1, List<String> urlsTempG2) {
37+
// TODO Auto-generated method stub
38+
39+
}
40+
41+
@Override
42+
public long register(ConsumerRegisterRequest request) {
43+
// TODO Auto-generated method stub
44+
return 0;
45+
}
46+
47+
@Override
48+
public void publishAndUpdateResultFailMsg(FailMsgPublishAndUpdateResultRequest request) {
49+
// TODO Auto-generated method stub
50+
51+
}
52+
53+
@Override
54+
public void deRegister(ConsumerDeRegisterRequest request) {
55+
// TODO Auto-generated method stub
56+
57+
}
58+
59+
@Override
60+
public GetMetaGroupResponse getMetaGroup(GetMetaGroupRequest request) {
61+
// TODO Auto-generated method stub
62+
return null;
63+
}
64+
65+
@Override
66+
public GetTopicResponse getTopic(GetTopicRequest request) {
67+
// TODO Auto-generated method stub
68+
return null;
69+
}
70+
71+
@Override
72+
public GetGroupTopicResponse getGroupTopic(GetGroupTopicRequest request) {
73+
// TODO Auto-generated method stub
74+
return null;
75+
}
76+
77+
@Override
78+
public void addCat(CatRequest request) {
79+
// TODO Auto-generated method stub
80+
81+
}
82+
83+
@Override
84+
public boolean publish(PublishMessageRequest request, int retryTimes) {
85+
// TODO Auto-generated method stub
86+
return false;
87+
}
88+
89+
@Override
90+
public boolean publish(PublishMessageRequest request) {
91+
// TODO Auto-generated method stub
92+
return false;
93+
}
94+
95+
@Override
96+
public void commitOffset(CommitOffsetRequest request) {
97+
// TODO Auto-generated method stub
98+
99+
}
100+
101+
@Override
102+
public ConsumerGroupRegisterResponse registerConsumerGroup(ConsumerGroupRegisterRequest request) {
103+
// TODO Auto-generated method stub
104+
return null;
105+
}
106+
107+
@Override
108+
public void heartbeat(HeartbeatRequest request) {
109+
// TODO Auto-generated method stub
110+
111+
}
112+
113+
@Override
114+
public GetConsumerGroupResponse getConsumerGroup(GetConsumerGroupRequest request) {
115+
// TODO Auto-generated method stub
116+
return null;
117+
}
118+
119+
@Override
120+
public GetMessageCountResponse getMessageCount(GetMessageCountRequest request) {
121+
// TODO Auto-generated method stub
122+
return null;
123+
}
124+
125+
@Override
126+
public PullDataResponse pullData(PullDataRequest request) {
127+
// TODO Auto-generated method stub
128+
return null;
129+
}
130+
131+
@Override
132+
public GetTopicQueueIdsResponse getTopicQueueIds(GetTopicQueueIdsRequest request) {
133+
// TODO Auto-generated method stub
134+
return null;
135+
}
136+
137+
@Override
138+
public void addLog(LogRequest request) {
139+
// TODO Auto-generated method stub
140+
141+
}
142+
143+
@Override
144+
public void addOpLog(OpLogRequest request) {
145+
// TODO Auto-generated method stub
146+
147+
}
148+
149+
@Override
150+
public void sendMail(SendMailRequest request) {
151+
// TODO Auto-generated method stub
152+
153+
}
154+
155+
}

‎mq-client/mq-client-core/src/test/java/com/ppdai/infrastructure/mq/client/AbstractTest.java‎

Lines changed: 118 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,118 @@
1+
package com.ppdai.infrastructure.mq.client;
2+
3+
import java.lang.reflect.Field;
4+
import java.util.HashMap;
5+
import java.util.Map;
6+
7+
import com.ppdai.infrastructure.mq.biz.dto.base.ConsumerGroupMetaDto;
8+
import com.ppdai.infrastructure.mq.biz.dto.base.ConsumerQueueDto;
9+
import com.ppdai.infrastructure.mq.biz.dto.client.ConsumerGroupOneDto;
10+
11+
public abstract class AbstractTest {
12+
public static String consumerGroupName = "TestSub";
13+
public static String topicName = "test";
14+
15+
public static ConsumerGroupOneDto buildModifyConsumerGroupOne() {
16+
ConsumerGroupOneDto consumerGroupOneDto = new ConsumerGroupOneDto();
17+
ConsumerGroupMetaDto meta = new ConsumerGroupMetaDto();
18+
meta.setMetaVersion(11L);
19+
meta.setRbVersion(11L);
20+
meta.setVersion(1L);
21+
meta.setName(consumerGroupName);
22+
consumerGroupOneDto.setMeta(meta);
23+
Map<Long, ConsumerQueueDto> queues = new HashMap<Long, ConsumerQueueDto>();
24+
ConsumerQueueDto consumerQueueDto = buildModifyConsumerQueueDto();
25+
queues.put(1L, consumerQueueDto);
26+
consumerGroupOneDto.setQueues(queues);
27+
return consumerGroupOneDto;
28+
}
29+
30+
public static ConsumerQueueDto buildModifyConsumerQueueDto() {
31+
ConsumerQueueDto consumerQueueDto = new ConsumerQueueDto();
32+
consumerQueueDto.setConsumerBatchSize(11);
33+
consumerQueueDto.setConsumerGroupName(consumerGroupName);
34+
consumerQueueDto.setDelayProcessTime(11);
35+
consumerQueueDto.setLastId(0L);
36+
consumerQueueDto.setMaxPullTime(11);
37+
consumerQueueDto.setOffset(11L);
38+
consumerQueueDto.setOffsetVersion(11L);
39+
consumerQueueDto.setOriginTopicName(topicName);
40+
consumerQueueDto.setPullBatchSize(11);
41+
consumerQueueDto.setQueueId(1L);
42+
consumerQueueDto.setQueueOffsetId(11L);
43+
consumerQueueDto.setRetryCount(11);
44+
consumerQueueDto.setStopFlag(1);
45+
consumerQueueDto.setTag("11");
46+
consumerQueueDto.setThreadSize(110);
47+
consumerQueueDto.setTimeout(11);
48+
consumerQueueDto.setTopicId(11);
49+
consumerQueueDto.setTopicName(topicName);
50+
consumerQueueDto.setTopicType(11);
51+
consumerQueueDto.setTraceFlag(11);
52+
return consumerQueueDto;
53+
}
54+
55+
public static ConsumerGroupOneDto buildConsumerGroupOne() {
56+
ConsumerGroupOneDto consumerGroupOneDto = new ConsumerGroupOneDto();
57+
ConsumerGroupMetaDto meta = new ConsumerGroupMetaDto();
58+
meta.setMetaVersion(1L);
59+
meta.setRbVersion(1L);
60+
meta.setVersion(1L);
61+
meta.setName(consumerGroupName);
62+
consumerGroupOneDto.setMeta(meta);
63+
Map<Long, ConsumerQueueDto> queues = new HashMap<Long, ConsumerQueueDto>();
64+
ConsumerQueueDto consumerQueueDto = buildDefaultConsumerQueueDto();
65+
queues.put(1L, consumerQueueDto);
66+
consumerGroupOneDto.setQueues(queues);
67+
return consumerGroupOneDto;
68+
}
69+
70+
public static ConsumerQueueDto buildDefaultConsumerQueueDto() {
71+
ConsumerQueueDto consumerQueueDto = new ConsumerQueueDto();
72+
consumerQueueDto.setConsumerBatchSize(1);
73+
consumerQueueDto.setConsumerGroupName(consumerGroupName);
74+
consumerQueueDto.setDelayProcessTime(1);
75+
consumerQueueDto.setLastId(1L);
76+
consumerQueueDto.setMaxPullTime(1);
77+
consumerQueueDto.setOffset(10L);
78+
consumerQueueDto.setOffsetVersion(1L);
79+
consumerQueueDto.setOriginTopicName(topicName);
80+
consumerQueueDto.setPullBatchSize(1);
81+
consumerQueueDto.setQueueId(1L);
82+
consumerQueueDto.setQueueOffsetId(1L);
83+
consumerQueueDto.setRetryCount(1);
84+
consumerQueueDto.setStopFlag(0);
85+
consumerQueueDto.setTag("1");
86+
consumerQueueDto.setThreadSize(10);
87+
consumerQueueDto.setTimeout(1);
88+
consumerQueueDto.setTopicId(1);
89+
consumerQueueDto.setTopicName(topicName);
90+
consumerQueueDto.setTopicType(1);
91+
consumerQueueDto.setTraceFlag(1);
92+
return consumerQueueDto;
93+
}
94+
95+
public static <T> T getValue(String fieldName, Object object) {
96+
try {
97+
Field field = object.getClass().getDeclaredField(fieldName);
98+
field.setAccessible(true);
99+
Object rs = field.get(object);
100+
//field.setAccessible(false);
101+
return (T)rs;
102+
} catch (Exception e) {
103+
return null;
104+
}
105+
}
106+
107+
public static void setValue(String fieldName,Object value, Object object) {
108+
try {
109+
Field field = object.getClass().getDeclaredField(fieldName);
110+
field.setAccessible(true);
111+
field.set(object, value);
112+
//field.setAccessible(false);
113+
114+
} catch (Exception e) {
115+
116+
}
117+
}
118+
}

‎mq-client/mq-client-core/src/test/java/com/ppdai/infrastructure/mq/client/AllClientCoreTests.java‎

Lines changed: 30 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,30 @@
1+
//package com.ppdai.infrastructure.mq.client;
2+
//
3+
//import org.junit.runner.RunWith;
4+
//import org.junit.runners.Suite;
5+
//import org.junit.runners.Suite.SuiteClasses;
6+
//
7+
//import com.ppdai.infrastructure.mq.client.config.ClientConfighelperTest;
8+
//import com.ppdai.infrastructure.mq.client.config.ConsumerGroupVoTest;
9+
//import com.ppdai.infrastructure.mq.client.core.impl.ConsumerPollingServiceTest;
10+
//import com.ppdai.infrastructure.mq.client.core.impl.MqBrokerUrlRefreshServiceTest;
11+
//import com.ppdai.infrastructure.mq.client.core.impl.MqCheckServiceTest;
12+
//import com.ppdai.infrastructure.mq.client.core.impl.MqGroupExcutorServiceTest;
13+
//import com.ppdai.infrastructure.mq.client.core.impl.MqHeartbeatServiceTest;
14+
//import com.ppdai.infrastructure.mq.client.core.impl.MqMeticReporterServiceTest;
15+
//import com.ppdai.infrastructure.mq.client.core.impl.MqMetricReporterTest;
16+
//import com.ppdai.infrastructure.mq.client.core.impl.MqQueueExcutorServiceTest;
17+
//import com.ppdai.infrastructure.mq.client.core.impl.MqTopicQueueRefreshServiceTest;
18+
//import com.ppdai.infrastructure.mq.client.exception.ExceptionTest;
19+
//import com.ppdai.infrastructure.mq.client.factory.MqFactoryTest;
20+
//import com.ppdai.infrastructure.mq.client.resource.MqResourceTest;
21+
//
22+
//@RunWith(Suite.class)
23+
//@SuiteClasses({ ClientConfighelperTest.class, ConsumerPollingServiceTest.class, MqBrokerUrlRefreshServiceTest.class,
24+
// MqCheckServiceTest.class, MqGroupExcutorServiceTest.class, MqHeartbeatServiceTest.class,
25+
// MqQueueExcutorServiceTest.class, MqMetricReporterTest.class, MqMeticReporterServiceTest.class,
26+
// MqTopicQueueRefreshServiceTest.class, ConsumerGroupVoTest.class, MqFactoryTest.class, ExceptionTest.class,
27+
// MqResourceTest.class, MqClientTest.class, MessageUtilTest.class, MqConfigTest.class })
28+
//public class AllClientCoreTests {
29+
//
30+
//}

‎mq-client/mq-client-core/src/test/java/com/ppdai/infrastructure/mq/client/MessageUtilTest.java‎

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,18 @@
1+
package com.ppdai.infrastructure.mq.client;
2+
3+
import java.util.Arrays;
4+
5+
import org.junit.Test;
6+
import org.junit.runner.RunWith;
7+
import org.junit.runners.JUnit4;
8+
9+
import com.ppdai.infrastructure.mq.biz.dto.base.MessageDto;
10+
11+
@RunWith(JUnit4.class)
12+
public class MessageUtilTest {
13+
@Test
14+
public void messageUtilTest() {
15+
MessageUtil.addCatChain(Arrays.asList(new MessageDto()));
16+
MessageUtil.checkMessageExceed65535(null);
17+
}
18+
}

0 commit comments

Comments
 (0)