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

Question

我正在尝试在Windows上运行SocketTextStreamWordCount。我找不到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("Hin");
            bw.flush();
            System.out.println("Sending Hi");
        }
    }
    catch(IOException i)
    {
        System.out.println(i);
    }
}

Answer 2

已安装https://nmap.org/这似乎奏效了。