rename[test]: rename test unit

This commit is contained in:
godotg
2022-12-12 16:10:08 +08:00
parent 9e0fed2a88
commit a551e18de7
93 changed files with 96 additions and 96 deletions
@@ -19,7 +19,7 @@ import org.junit.Test;
/**
* 定长通信
*
* @author jaysunxiao
* @author godotg
* @version 1.0
* @since 2017 05.22 18:23
*/
@@ -6,7 +6,7 @@ import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
/**
* @author jaysunxiao
* @author godotg
* @version 1.0
* @since 2017 05.31 10:22
*/
@@ -17,7 +17,7 @@ import org.junit.Ignore;
import org.junit.Test;
/**
* @author jaysunxiao
* @author godotg
* @version 1.0
* @since 2017 05.31 10:22
*/
@@ -11,7 +11,7 @@ import java.io.IOException;
import java.io.RandomAccessFile;
/**
* @author jaysunxiao
* @author godotg
* @version 1.0
* @since 2017 05.31 09:58
*/
@@ -21,7 +21,7 @@ import org.junit.Test;
/**
* 通过netty的通信,和java原生的RandomAccessFile来实现小文件的传输
*
* @author jaysunxiao
* @author godotg
* @version 1.0
* @since 2017 05.31 09:49
*/
@@ -4,7 +4,7 @@ import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
/**
* @author jaysunxiao
* @author godotg
* @version 1.0
* @since 2017 05.23 18:02
*/
@@ -4,7 +4,7 @@ import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
/**
* @author jaysunxiao
* @author godotg
* @version 1.0
* @since 2017 05.23 17:13
*/
@@ -16,7 +16,7 @@ import org.junit.Ignore;
import org.junit.Test;
/**
* @author jaysunxiao
* @author godotg
* @version 1.0
* @since 2017 05.23 18:02
*/
@@ -3,7 +3,7 @@ package com.zfoo.net.base.netty.subscribe;
import java.io.Serializable;
/**
* @author jaysunxiao
* @author godotg
* @version 1.0
* @since 2017 05.23 16:51
*/
@@ -3,7 +3,7 @@ package com.zfoo.net.base.netty.subscribe;
import java.io.Serializable;
/**
* @author jaysunxiao
* @author godotg
* @version 1.0
* @since 2017 05.23 16:52
*/
@@ -20,7 +20,7 @@ import org.junit.Test;
/**
* 对象读写序列化通信
*
* @author jaysunxiao
* @author godotg
* @version 1.0
* @since 2017 05.23 16:51
*/
@@ -15,7 +15,7 @@ import org.junit.Test;
/**
* 没有考虑到半包读写的服务器
*
* @author jaysunxiao
* @author godotg
* @version 1.0
* @since 2017 05.22 18:23
*/
@@ -17,7 +17,7 @@ import org.junit.Test;
/**
* 通过换行符解决半包读写的问题
*
* @author jaysunxiao
* @author godotg
* @version 1.0
* @since 2017 05.22 18:23
*/
@@ -7,7 +7,7 @@ import io.netty.channel.socket.DatagramPacket;
import io.netty.util.CharsetUtil;
/**
* @author jaysunxiao
* @author godotg
* @version 1.0
* @since 2017 05.27 17:48
*/
@@ -17,7 +17,7 @@ import org.junit.Test;
import java.net.InetSocketAddress;
/**
* @author jaysunxiao
* @author godotg
* @version 1.0
* @since 2017 05.27 17:48
*/
@@ -7,7 +7,7 @@ import io.netty.channel.socket.DatagramPacket;
import io.netty.util.CharsetUtil;
/**
* @author jaysunxiao
* @author godotg
* @version 1.0
* @since 2017 05.27 17:27
*/
@@ -13,7 +13,7 @@ import org.junit.Test;
/**
* UDP通信
*
* @author jaysunxiao
* @author godotg
* @version 1.0
* @since 2017 05.27 17:24
*/
@@ -27,7 +27,7 @@ import org.junit.Test;
import java.util.List;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class RegistryTest {
@@ -21,7 +21,7 @@ import com.zfoo.protocol.util.JsonUtils;
import org.springframework.stereotype.Component;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
@Component
@@ -22,7 +22,7 @@ import org.junit.Test;
import org.springframework.context.support.ClassPathXmlApplicationContext;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
@Ignore
@@ -25,7 +25,7 @@ import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
@Component
@@ -33,7 +33,7 @@ import java.util.concurrent.atomic.AtomicInteger;
/**
* 这是客户端连接网关,网关转发到服务提供者的测试用例
*
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
@Ignore
@@ -21,7 +21,7 @@ import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
@Component
@@ -25,7 +25,7 @@ import org.slf4j.LoggerFactory;
import org.springframework.context.support.ClassPathXmlApplicationContext;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
@Ignore
@@ -23,7 +23,7 @@ import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
@Component
@@ -21,7 +21,7 @@ import org.junit.Test;
import org.springframework.context.support.ClassPathXmlApplicationContext;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
@Ignore
@@ -24,7 +24,7 @@ import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
@Component
@@ -28,7 +28,7 @@ import org.springframework.context.support.ClassPathXmlApplicationContext;
import java.util.concurrent.atomic.AtomicInteger;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
@Ignore
@@ -22,7 +22,7 @@ import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
@Component
@@ -25,7 +25,7 @@ import org.slf4j.LoggerFactory;
import org.springframework.context.support.ClassPathXmlApplicationContext;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
@Ignore
@@ -23,7 +23,7 @@ import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
@Component
@@ -21,7 +21,7 @@ import org.junit.Test;
import org.springframework.context.support.ClassPathXmlApplicationContext;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
@Ignore
@@ -27,7 +27,7 @@ import org.slf4j.LoggerFactory;
import org.springframework.context.support.ClassPathXmlApplicationContext;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
@Ignore
@@ -23,7 +23,7 @@ import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
@Component
@@ -21,7 +21,7 @@ import org.junit.Test;
import org.springframework.context.support.ClassPathXmlApplicationContext;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
@Ignore
@@ -27,7 +27,7 @@ import org.slf4j.LoggerFactory;
import org.springframework.context.support.ClassPathXmlApplicationContext;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
@Ignore
@@ -21,7 +21,7 @@ import org.junit.Test;
import org.springframework.context.support.ClassPathXmlApplicationContext;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
@Ignore
@@ -23,7 +23,7 @@ import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
@Component
@@ -22,7 +22,7 @@ import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
@Component
@@ -23,7 +23,7 @@ import org.junit.Test;
import org.springframework.context.support.ClassPathXmlApplicationContext;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
@Ignore
@@ -24,7 +24,7 @@ import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
@Component
@@ -20,7 +20,7 @@ import org.junit.Test;
import org.springframework.context.support.ClassPathXmlApplicationContext;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
@Ignore
@@ -22,7 +22,7 @@ import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
@Component
@@ -24,7 +24,7 @@ import org.junit.Test;
import org.springframework.context.support.ClassPathXmlApplicationContext;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
@Ignore
@@ -23,7 +23,7 @@ import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
@Component
@@ -21,7 +21,7 @@ import org.junit.Test;
import org.springframework.context.support.ClassPathXmlApplicationContext;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
@Ignore
@@ -18,7 +18,7 @@ import com.zfoo.protocol.IPacket;
import java.util.Arrays;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class CM_Array implements IPacket {
@@ -18,7 +18,7 @@ import com.zfoo.protocol.IPacket;
import java.util.Objects;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class CM_Float implements IPacket {
@@ -18,7 +18,7 @@ import com.zfoo.protocol.IPacket;
import java.util.Objects;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class CM_Int implements IPacket {
@@ -20,7 +20,7 @@ import java.util.Map;
import java.util.Objects;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class CM_List implements IPacket {
@@ -20,7 +20,7 @@ import java.util.Map;
import java.util.Objects;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class CM_Map implements IPacket {
@@ -18,7 +18,7 @@ import com.zfoo.protocol.IPacket;
import java.util.Objects;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class CM_Object implements IPacket {
@@ -21,7 +21,7 @@ import java.util.Objects;
import java.util.Set;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class CM_Set implements IPacket {
@@ -18,7 +18,7 @@ import com.zfoo.protocol.IPacket;
import java.util.Objects;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class ObjectA implements IPacket {
@@ -18,7 +18,7 @@ import com.zfoo.protocol.IPacket;
import java.util.Objects;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class ObjectB implements IPacket {
@@ -16,7 +16,7 @@ package com.zfoo.net.packet;
import com.zfoo.protocol.IPacket;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class SM_Float implements IPacket {
@@ -18,7 +18,7 @@ import com.zfoo.protocol.IPacket;
import java.util.Objects;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class SM_Int implements IPacket {
@@ -16,7 +16,7 @@ package com.zfoo.net.packet;
import com.zfoo.protocol.IPacket;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class SM_Object implements IPacket {
@@ -20,7 +20,7 @@ import java.util.Map;
import java.util.Set;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class CM_CSharpRequest implements IPacket {
@@ -16,7 +16,7 @@ package com.zfoo.net.packet.csharp;
import com.zfoo.protocol.IPacket;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class CSharpObjectA implements IPacket {
@@ -16,7 +16,7 @@ package com.zfoo.net.packet.csharp;
import com.zfoo.protocol.IPacket;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class CSharpObjectB implements IPacket {
@@ -16,7 +16,7 @@ package com.zfoo.net.packet.gateway;
import com.zfoo.protocol.IPacket;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class GatewayToProviderRequest implements IPacket {
@@ -16,7 +16,7 @@ package com.zfoo.net.packet.gateway;
import com.zfoo.protocol.IPacket;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class GatewayToProviderResponse implements IPacket {
@@ -16,7 +16,7 @@ import com.baidu.bjf.remoting.protobuf.annotation.Protobuf;
import com.zfoo.protocol.IPacket;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class JProtobufHelloRequest implements IPacket {
@@ -16,7 +16,7 @@ import com.baidu.bjf.remoting.protobuf.annotation.Protobuf;
import com.zfoo.protocol.IPacket;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class JProtobufHelloResponse implements IPacket {
@@ -16,7 +16,7 @@ package com.zfoo.net.packet.provider;
import com.zfoo.protocol.IPacket;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class ProviderMessAnswer implements IPacket {
@@ -16,7 +16,7 @@ package com.zfoo.net.packet.provider;
import com.zfoo.protocol.IPacket;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class ProviderMessAsk implements IPacket {
@@ -15,7 +15,7 @@ package com.zfoo.net.packet.tcp;
import com.zfoo.protocol.IPacket;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class AsyncMessAnswer implements IPacket {
@@ -15,7 +15,7 @@ package com.zfoo.net.packet.tcp;
import com.zfoo.protocol.IPacket;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class AsyncMessAsk implements IPacket {
@@ -15,7 +15,7 @@ package com.zfoo.net.packet.tcp;
import com.zfoo.protocol.IPacket;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class SyncMessAnswer implements IPacket {
@@ -15,7 +15,7 @@ package com.zfoo.net.packet.tcp;
import com.zfoo.protocol.IPacket;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class SyncMessAsk implements IPacket {
@@ -15,7 +15,7 @@ package com.zfoo.net.packet.tcp;
import com.zfoo.protocol.IPacket;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class TcpHelloRequest implements IPacket {
@@ -15,7 +15,7 @@ package com.zfoo.net.packet.tcp;
import com.zfoo.protocol.IPacket;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class TcpHelloResponse implements IPacket {
@@ -15,7 +15,7 @@ package com.zfoo.net.packet.udp;
import com.zfoo.protocol.IPacket;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class UdpHelloRequest implements IPacket {
@@ -15,7 +15,7 @@ package com.zfoo.net.packet.udp;
import com.zfoo.protocol.IPacket;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class UdpHelloResponse implements IPacket {
@@ -18,7 +18,7 @@ import com.zfoo.protocol.IPacket;
import java.util.Objects;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class WebSocketObjectA implements IPacket {
@@ -18,7 +18,7 @@ import com.zfoo.protocol.IPacket;
import java.util.Objects;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class WebSocketObjectB implements IPacket {
@@ -20,7 +20,7 @@ import java.util.Map;
import java.util.Set;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class WebSocketPacketRequest implements IPacket {
@@ -15,7 +15,7 @@ package com.zfoo.net.packet.websocket;
import com.zfoo.protocol.IPacket;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class WebsocketHelloRequest implements IPacket {
@@ -15,7 +15,7 @@ package com.zfoo.net.packet.websocket;
import com.zfoo.protocol.IPacket;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class WebsocketHelloResponse implements IPacket {
@@ -31,7 +31,7 @@ import java.util.Map;
import java.util.Set;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public class ProtocolTest {
@@ -20,7 +20,7 @@ import com.zfoo.protocol.util.StringUtils;
import com.zfoo.util.ThreadUtils;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
public abstract class SessionUtils {
@@ -23,7 +23,7 @@ import java.util.function.Function;
import java.util.stream.Collectors;
/**
* @author jaysunxiao
* @author godotg
* @version 3.0
*/
@Ignore
@@ -32,7 +32,7 @@ public class CreateNodeSyncAuthTest {
@Test
public void generateDigestTest() throws NoSuchAlgorithmException {
String digest = DigestAuthenticationProvider.generateDigest("jaysunxiao:123456");
String digest = DigestAuthenticationProvider.generateDigest("godotg:123456");
System.out.println(digest);
}
@@ -64,7 +64,7 @@ public class CreateNodeSyncAuthTest {
// ACL access control list
ACL aclIp = new ACL(Perms.READ, new Id("ip", "192.168.1.105"));
ACL aclDigest = new ACL(Perms.READ | Perms.WRITE, new Id("digest", DigestAuthenticationProvider.generateDigest("jaysunxiao:123456")));// 用户名+密码
ACL aclDigest = new ACL(Perms.READ | Perms.WRITE, new Id("digest", DigestAuthenticationProvider.generateDigest("godotg:123456")));// 用户名+密码
ArrayList<ACL> acls = new ArrayList<>();
acls.add(aclDigest);
@@ -85,7 +85,7 @@ public class CreateNodeSyncAuthTest {
try {
// 下面两句设置ACL的哪些author可以访问
zookeeper.addAuthInfo("digest", "jaysunxiao:123456".getBytes());
zookeeper.addAuthInfo("digest", "godotg:123456".getBytes());
zookeeper.getData("/node_test", false, stat);
somethingDone = true;
} catch (Exception e) {
@@ -12,7 +12,7 @@ import org.junit.Ignore;
import org.junit.Test;
/**
* @author jaysunxiao
* @author godotg
* @version 1.0
* @since 2019-08-25 09:43
*/
@@ -15,7 +15,7 @@ import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
/**
* @author jaysunxiao
* @author godotg
* @version 1.0
* @since 2018-08-01 16:43
*/
@@ -34,7 +34,7 @@ public class CreateNodeAuthTest {
curator.start();
ACL aclIp = new ACL(Perms.READ, new Id("ip", "192.168.1.105"));
ACL aclDigest = new ACL(Perms.READ | Perms.WRITE, new Id("digest", DigestAuthenticationProvider.generateDigest("jaysunxiao:123456")));
ACL aclDigest = new ACL(Perms.READ | Perms.WRITE, new Id("digest", DigestAuthenticationProvider.generateDigest("godotg:123456")));
ArrayList<ACL> acls = new ArrayList<>();
acls.add(aclDigest);
acls.add(aclIp);
@@ -60,7 +60,7 @@ public class CreateNodeAuthTest {
.builder()
.connectString("localhost:2181")
.sessionTimeoutMs(5000)
.authorization("digest", "jaysunxiao:123456".getBytes()) // 授权访问
.authorization("digest", "godotg:123456".getBytes()) // 授权访问
.connectionTimeoutMs(5000)
.retryPolicy(retryPolicy)
.build();
@@ -13,7 +13,7 @@ import org.junit.Test;
/**
* 使用Curator实现分布式计数器
*
* @author jaysunxiao
* @author godotg
* @version 1.0
* @since 2018-08-03 16:09
*/
@@ -11,7 +11,7 @@ import org.junit.Test;
/**
* 使用Curator实现分布式Barrier
*
* @author jaysunxiao
* @author godotg
* @version 1.0
* @since 2018-08-03 16:16
*/
@@ -8,7 +8,7 @@ import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
/**
* @author jaysunxiao
* @author godotg
* @version 1.0
* @since 2018-08-03 16:13
*/
@@ -15,7 +15,7 @@ import java.util.concurrent.CountDownLatch;
/**
* 使用Curator实现分布式锁功能
*
* @author jaysunxiao
* @author godotg
* @version 1.0
* @since 2018-08-03 15:47
*/
@@ -8,7 +8,7 @@ import java.util.Date;
import java.util.concurrent.CountDownLatch;
/**
* @author jaysunxiao
* @author godotg
* @version 1.0
* @since 2018-08-03 15:46
*/
@@ -9,7 +9,7 @@ import org.junit.Ignore;
import org.junit.Test;
/**
* @author jaysunxiao
* @author godotg
* @version 1.0
* @since 2018-08-03 15:32
*/