diff --git a/dubbo-remoting/src/test/java/com/alibaba/dubbo/remoting/transport/netty/NettyClientTest.java b/dubbo-remoting/src/test/java/com/alibaba/dubbo/remoting/transport/netty/NettyClientTest.java deleted file mode 100644 index ecd869585c..0000000000 --- a/dubbo-remoting/src/test/java/com/alibaba/dubbo/remoting/transport/netty/NettyClientTest.java +++ /dev/null @@ -1,78 +0,0 @@ -/* - * Copyright 1999-2011 Alibaba Group. - * - * 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. - */ -package com.alibaba.dubbo.remoting.transport.netty; - -import java.util.ArrayList; -import java.util.List; - -import org.junit.AfterClass; -import org.junit.BeforeClass; -import org.junit.Test; - -import com.alibaba.dubbo.common.URL; -import com.alibaba.dubbo.remoting.Server; -import com.alibaba.dubbo.remoting.exchange.ExchangeChannel; -import com.alibaba.dubbo.remoting.exchange.Exchangers; - -/** - * User: heyman - * Date: 5/3/11 - * Time: 5:47 PM - */ -public class NettyClientTest { - static Server server; - - - @BeforeClass - public static void setUp() throws Exception { - /*int port = (int) (1000 * Math.random() + 10000); - //System.out.println(port);*/ - server = Exchangers.bind(URL.valueOf("exchange://localhost:10001?server=netty"), new TelnetServerHandler()); - } - - @Test - public void testClientClose() throws Exception { - List clients = new ArrayList(100); - for (int i = 0; i < 100; i++) { - ExchangeChannel client = Exchangers.connect(URL.valueOf("exchange://localhost:10001?client=netty")); - Thread.sleep(5); - clients.add(client); - } - for (ExchangeChannel client : clients){ - client.close(); - } - Thread.sleep(1000); - } - - @Test - public void testServerClose() throws Exception { - for (int i = 0; i < 100; i++) { - Server aServer = Exchangers.bind(URL.valueOf("exchange://localhost:" + (5000 + i) + "?client=netty"), new TelnetServerHandler()); - System.out.println(i); - aServer.close(); - } - } - - @AfterClass - public static void tearDown() throws Exception { - try { - if (server != null) - server.close(); - } finally { - - } - } -} \ No newline at end of file diff --git a/dubbo-remoting/src/test/java/com/alibaba/dubbo/remoting/transport/netty/NettyClientToServerTest.java b/dubbo-remoting/src/test/java/com/alibaba/dubbo/remoting/transport/netty/NettyClientToServerTest.java deleted file mode 100644 index 73e41fd774..0000000000 --- a/dubbo-remoting/src/test/java/com/alibaba/dubbo/remoting/transport/netty/NettyClientToServerTest.java +++ /dev/null @@ -1,43 +0,0 @@ -/* - * Copyright 1999-2011 Alibaba Group. - * - * 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. - */ -package com.alibaba.dubbo.remoting.transport.netty; - -import com.alibaba.dubbo.common.URL; -import com.alibaba.dubbo.remoting.RemotingException; -import com.alibaba.dubbo.remoting.exchange.ExchangeChannel; -import com.alibaba.dubbo.remoting.exchange.ExchangeServer; -import com.alibaba.dubbo.remoting.exchange.Exchangers; -import com.alibaba.dubbo.remoting.exchange.support.Replier; -import com.alibaba.dubbo.remoting.transport.ClientToServerTest; - -/** - * NettyClientToServerTest - * - * @author william.liangf - */ -public class NettyClientToServerTest extends ClientToServerTest { - - @Override - protected ExchangeServer newServer(int port, Replier receiver) throws RemotingException { - return Exchangers.bind(URL.valueOf("exchange://localhost:" + port + "?server=netty"), receiver); - } - - @Override - protected ExchangeChannel newClient(int port) throws RemotingException { - return Exchangers.connect(URL.valueOf("exchange://localhost:" + port + "?client=netty")); - } - -} \ No newline at end of file diff --git a/dubbo-remoting/src/test/java/com/alibaba/dubbo/remoting/transport/netty/NettyStringTest.java b/dubbo-remoting/src/test/java/com/alibaba/dubbo/remoting/transport/netty/NettyStringTest.java deleted file mode 100644 index dfb8405b06..0000000000 --- a/dubbo-remoting/src/test/java/com/alibaba/dubbo/remoting/transport/netty/NettyStringTest.java +++ /dev/null @@ -1,64 +0,0 @@ -/* - * Copyright 1999-2011 Alibaba Group. - * - * 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. - */ -package com.alibaba.dubbo.remoting.transport.netty; - -import org.junit.AfterClass; -import org.junit.BeforeClass; -import org.junit.Test; - -import com.alibaba.dubbo.common.URL; -import com.alibaba.dubbo.remoting.exchange.ExchangeChannel; -import com.alibaba.dubbo.remoting.exchange.ExchangeServer; -import com.alibaba.dubbo.remoting.exchange.Exchangers; - -/** - * User: heyman - * Date: 4/26/11 - * Time: 4:13 PM - */ -public class NettyStringTest { - static ExchangeServer server; - static ExchangeChannel client; - - @BeforeClass - public static void setUp() throws Exception { - //int port = (int) (1000 * Math.random() + 10000); - int port = 10001; - System.out.println(port); - server = Exchangers.bind(URL.valueOf("telnet://0.0.0.0:" + port + "?server=netty"), new TelnetServerHandler()); - client = Exchangers.connect(URL.valueOf("telnet://127.0.0.1:" + port + "?client=netty"), new TelnetClientHandler()); - } - - @Test - public void testHandler() throws Exception { - //Thread.sleep(20000); - /*client.request("world\r\n"); - Future future = client.request("world", 10000); - String result = (String)future.get(); - Assert.assertEquals("Did you say 'world'?\r\n",result);*/ - } - - @AfterClass - public static void tearDown() throws Exception { - try { - if (server != null) - server.close(); - } finally { - if (client != null) - client.close(); - } - } -} \ No newline at end of file diff --git a/dubbo-remoting/src/test/java/com/alibaba/dubbo/remoting/transport/netty/TelnetClientHandler.java b/dubbo-remoting/src/test/java/com/alibaba/dubbo/remoting/transport/netty/TelnetClientHandler.java deleted file mode 100644 index 9f1aae580f..0000000000 --- a/dubbo-remoting/src/test/java/com/alibaba/dubbo/remoting/transport/netty/TelnetClientHandler.java +++ /dev/null @@ -1,36 +0,0 @@ -/* - * Copyright 1999-2011 Alibaba Group. - * - * 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. - */ -package com.alibaba.dubbo.remoting.transport.netty; - -import com.alibaba.dubbo.remoting.RemotingException; -import com.alibaba.dubbo.remoting.exchange.ExchangeChannel; -import com.alibaba.dubbo.remoting.exchange.support.Replier; - -/** - * User: heyman - * Date: 4/28/11 - * Time: 11:15 AM - */ -public class TelnetClientHandler implements Replier { - - public Class interest() { - return String.class; - } - - public Object reply(ExchangeChannel channel, String msg) throws RemotingException { - return msg; - } -} \ No newline at end of file diff --git a/dubbo-remoting/src/test/java/com/alibaba/dubbo/remoting/transport/netty/TelnetServerHandler.java b/dubbo-remoting/src/test/java/com/alibaba/dubbo/remoting/transport/netty/TelnetServerHandler.java deleted file mode 100644 index ac5701b240..0000000000 --- a/dubbo-remoting/src/test/java/com/alibaba/dubbo/remoting/transport/netty/TelnetServerHandler.java +++ /dev/null @@ -1,46 +0,0 @@ -/* - * Copyright 1999-2011 Alibaba Group. - * - * 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. - */ -package com.alibaba.dubbo.remoting.transport.netty; - -import com.alibaba.dubbo.remoting.RemotingException; -import com.alibaba.dubbo.remoting.exchange.ExchangeChannel; -import com.alibaba.dubbo.remoting.exchange.support.Replier; - -/** - * User: heyman - * Date: 4/26/11 - * Time: 4:29 PM - */ -public class TelnetServerHandler implements Replier { - - public Class interest() { - return String.class; - } - - public Object reply(ExchangeChannel channel, String msg) throws RemotingException { - // Generate and write a response. - - String response; - if (msg.length() == 0) { - response = "Please type something.\r\n"; - } else { - response = "Did you say '" + msg + "'?\r\n"; - } - //System.out.println(response); - return response; - } - -} \ No newline at end of file