natas_hw
/
dubbo
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改测试依赖 

git-svn-id: http://code.alibabatech.com/svn/dubbo/trunk@106 1a56cb94-b969-4eaa-88fa-be21384802f2
This commit is contained in:
william.liangf 2011-10-28 07:23:23 +00:00
parent fd8d2cb72c
commit dc4c0b0d30
5 changed files with 0 additions and 267 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

78
dubbo-remoting/src/test/java/com/alibaba/dubbo/remoting/transport/netty/NettyClientTest.java
View File

@ -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<ExchangeChannel> clients = new ArrayList<ExchangeChannel>(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 {
}
}
}

43
dubbo-remoting/src/test/java/com/alibaba/dubbo/remoting/transport/netty/NettyClientToServerTest.java
View File

@ -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"));
}
}

64
dubbo-remoting/src/test/java/com/alibaba/dubbo/remoting/transport/netty/NettyStringTest.java
View File

@ -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();
}
}
}

36
dubbo-remoting/src/test/java/com/alibaba/dubbo/remoting/transport/netty/TelnetClientHandler.java
View File

@ -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<String> {
public Class<String> interest() {
return String.class;
}
public Object reply(ExchangeChannel channel, String msg) throws RemotingException {
return msg;
}
}

46
dubbo-remoting/src/test/java/com/alibaba/dubbo/remoting/transport/netty/TelnetServerHandler.java
View File

@ -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<String> {
public Class<String> 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;
}
}