Netcat 运行 Flink 示例的 Java 代码替代方案 SocketTextStreamWordCount

Question

我正在尝试运行 SocketTextStreamWordCount 但在 Windows 上。我无法找到 netcat，那些在网上可用的内容不知何故被我的防病毒软件拒绝了。我如何编写基本的Java代码来将数据推送到这个Flink程序。我试过EchoServer和 EchoClient 示例来推送数据，但这似乎也不起作用。谁能帮我解决这个问题吗？

Answer 1

1. 运行以下 Java 代码，启动端口 5000 的服务器，该服务器在无限循环中发送文本 Hi。
2. 然后使用 5000 端口启动 Flink 客户端(SocketTextStreamWordCount 程序)。

您的 Flink 服务器现在可以打印 Hi 的字数

代码:

public static void main(String args[])
{
    try
    {
        int port = 5000;
        server = new ServerSocket(port);
        System.out.println("Server started");

        System.out.println("Waiting for a client ...");

        socket = server.accept();
        System.out.println("Client accepted");

        while(true) {
            OutputStream os = socket.getOutputStream();
            OutputStreamWriter osw = new OutputStreamWriter(os);
            BufferedWriter bw = new BufferedWriter(osw);
            bw.write("Hi\n");
            bw.flush();
            System.out.println("Sending Hi");
        }

    }
    catch(IOException i)
    {
        System.out.println(i);
    }
}