如何在Citrus中测试套接字服务器？
如何在Citrus中测试套接字服务器？
提问于 2015-12-30 18:34:33
我想对一个用Netty构建的套接字服务器进行一些单元测试。
套接字服务器有以下简单代码：
import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
public class SocketServer implements Runnable {
private int port;
private EventLoopGroup bossGroup;
private EventLoopGroup workerGroup;
private ChannelFuture channelFuture;
private ServerBootstrap bootstrap;
public SocketServer(int port) {
this.port = port;
this.bossGroup = new NioEventLoopGroup();
this.workerGroup = new NioEventLoopGroup();
}
public int getPort() {
return port;
}
@Override
public void run() {
try {
bootstrap = new ServerBootstrap();
bootstrap
.group(bossGroup, workerGroup)
.channel(NioServerSocketChannel.class)
.childHandler(new ChannelInitializer<SocketChannel>() {
@Override
public void initChannel(SocketChannel ch)
throws Exception {
ch.pipeline()
.addLast(new ReceiveMessageServerHandler())
.addLast(new ParseMessageServerHandler());
}
}).option(ChannelOption.SO_BACKLOG, 128).childOption(ChannelOption.SO_KEEPALIVE, true);
// Bind and start to accept incoming connections.
channelFuture = bootstrap.bind(port).sync();
// Wait until the server socket is closed
channelFuture.channel().closeFuture().sync();
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
workerGroup.shutdownGracefully();
bossGroup.shutdownGracefully();
}
}
public void shutdown() throws InterruptedException {
channelFuture.channel().close();
}
}在MessageHandlers上，我首先接收由'\n‘分隔的文本消息。我非常需要一个telnet客户。
我想测试我是否可以向服务器发送不同的消息，并且在一个时间框架内收到某些预期的响应。
我试过使用，但没有得到任何结果，因为它没有提供适当的纯文本协议(我尝试了Rest、Soap等，但它们对我没有好处)。我在柑橘参考文献2.4中找不到答案。
柑橘2.4参考- HTML版本
回答 2
Stack Overflow用户
回答已采纳
发布于 2015-12-30 18:34:33
我在发帖之前就解决了这个问题(我昨天写了这个问题，但直到今天我才发出来。)我找到了答案)。
所以我最终可以用Citrus框架和Spring集成来解决这个问题。
与同事一起阅读这篇文章之后，我能够使用适配器作为Citrus端点的通道(从SocketChannel到java.nio)工作。
弹簧集成参考- IP
在这里，您可能会看到我使用的柑橘-context.xml配置：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:citrus="http://www.citrusframework.org/schema/config"
xmlns:int="http://www.springframework.org/schema/integration"
xmlns:int-ip="http://www.springframework.org/schema/integration/ip"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
http://www.citrusframework.org/schema/config http://www.citrusframework.org/schema/config/citrus-config.xsd
http://www.springframework.org/schema/integration http://www.springframework.org/schema/integration/spring-integration.xsd
http://www.springframework.org/schema/integration/ip http://www.springframework.org/schema/integration/ip/spring-integration-ip.xsd">
<citrus:channel-endpoint id="citrusServiceEndpoint"
channel-name="input" />
<int-ip:tcp-connection-factory id="client"
type="client" host="localhost" port="9123" single-use="true"
so-timeout="10000" using-nio="true" />
<int:channel id="input" />
<int-ip:tcp-outbound-channel-adapter
id="outboundClient" channel="input" connection-factory="client" />
</beans>在我的柑橘测试中，我能够根据需要发送消息：
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.Test;
import com.consol.citrus.TestCaseMetaInfo.Status;
import com.consol.citrus.annotations.CitrusTest;
import com.consol.citrus.dsl.junit.JUnit4CitrusTestDesigner;
public class MyFirstTest extends JUnit4CitrusTestDesigner {
private static final int PORT = 9123;
private static SocketServer socketServer;
private static Thread socketThread;
@BeforeClass
public static void setUp() throws Exception {
socketServer = new SocketServer(PORT);
socketThread = new Thread(socketServer);
socketThread.start();
}
@AfterClass
public static void tearDown() throws Exception {
socketServer.shutdown();
socketThread.join();
}
@Test
@CitrusTest(name = "sendSpringIntegrationMessageTest")
public void sendSpringIntegrationMessageTest() {
status(Status.DRAFT);
send("citrusServiceEndpoint").payload("Message 1");
send("citrusServiceEndpoint").payload("Message 2");
}
}我希望这能帮助那些和我有同样问题的人。
Stack Overflow用户
发布于 2016-03-03 10:36:31
您还可以使用Citrus Apache Camel集成。您需要柑橘-骆驼模块和骆驼-网络(http://camel.apache.org/netty.html)或骆驼-网络4 (http://camel.apache.org/netty4.html)依赖。然后，您可以直接使用Camel Netty组件发送消息：
@Test
@CitrusTest
public void sendNettyMessageTest() {
status(Status.DRAFT);
//sends data to server
send("camel:netty4:tcp://localhost:9123").payload("Message 1");
send("camel:netty4:tcp://localhost:9123").payload("Message 2");
}这是利用Citrus中的动态端点，其中端点配置是在测试运行时创建的。所以这里几乎不需要额外的配置！
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/34535159
复制相关文章
相似问题
腾讯云开发者
