【问题标题】:java server to handle multiple tcp connectionsjava服务器处理多个tcp连接
【发布时间】:2010-09-12 13:53:12
【问题描述】:

我正在尝试用 java 编写一个简单的 Web 服务器。

现在我只有一个简单的程序,但我想扩展它,以便它可以通过建立多个 tcp 连接来服务多个浏览器。

我一直在阅读有关线程的文章。我的理解是,您可以创建一个新线程,并且它会继续,就好像它完全是另一个程序一样。所以有了一个新线程,就好像有 2 个 Web 服务器可以为 2 个浏览器提供服务,或者 x 个 Web 服务器可以为 x 个 Web 浏览器提供服务。

我对如何在 java 中创建新线程并为每个新线程提供连接有点迷茫。

我的想法是我会有一个像这样的循环,它获取新连接并将每个新连接传递给一个新线程

// make new ServerSocket
while (true) {
     Socket newConn = serverSocket.accept();
     // make new thread, and pass in newConn
}

有人能给我一些关于如何前进的指导吗? (如果我在某处犯了错误,请指出。我是线程编程的新手,所以完全有可能我没有正确理解它)

抢劫

编辑:

谢谢大家。

我去写了一些东西,那个java教程帮了很多。

我现在有一个新问题

我在新线程的 run() 方法中添加了一个循环,每当服务器接收到图像请求时,该循环包含 10 秒倒计时(使用 Thread.sleep(1000)),因此我可以查看哪些线程正在运行什么时候。 (index.html 中有 4 张图片)

所以我请求了 index.html 页面,我的服务器工作正常。然后我打开了大约十几个新标签。我的期望是对 index.html 页面的请求是即时的,但是图像发送到浏览器需要 10 秒(因为我放在那里的延迟),此时服务器会收到请求对于下一个 index.html 页面,依此类推。总的来说,我认为十几个 index.html 页面会立即提供服务,而在所有选项卡上提供 4 * 12 = 36 个图像需要 10 秒。

实际发生的情况是,获取前 4 张图片需要 10 秒,接下来的 4 张图片需要 10 秒,等等。因此,我的服务器不是提供多个网页,而是将请求排队并处理一个页面时间。

我认为我的程序有问题。但我觉得我可能无法正确理解浏览器如何与服务器交互。我认为浏览器在解析 html 页面时请求新对象。所以如果我打开十几个页面,我的服务器应该会收到几十个请求。我尝试在 FF 中打开几个选项卡,然后在 FF 中打开几个窗口,但这并没有帮助。

但是,当我打开 IE、FF 和 Chrome 并在不同时间(大约相隔 2 秒)请求 index.html 时,看起来每个浏览器都在同时接收页面,换句话说,在某一时刻,提供了 12 个不同的图像,每个浏览器 4 个

所以我想我正在寻找一些确认这是预期的行为?如果是这样,为什么我只能在打开 3 个不同的浏览器时看到这种行为,而在打开多个标签时却看不到?

(对于那些提出要求的人,我计划明年参加网络课程,但我现在正在尝试做一些基本的事情。所以一半是自学,一半是硬件)

【问题讨论】:

  • 这是用于家庭作业/自学还是用于商务?如果是后者,我强烈建议使用3rd party HTTP server API 而不是重新发明一个。 Jetty 很不错,它支持 JSP/Servlet。

标签: java multithreading sockets networking


【解决方案1】:

如果您正在寻找可靠的解决方案,请在线查找可行的解决方案。
如果是出于学习目的,请创建您自己的。
有几种方法可以做到这一点。最简单的方法是这样做取自Java Tutorial

import java.net.*;
import java.io.*;
public class MultiServer {
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = null;
        boolean listening = true;

        try {
            serverSocket = new ServerSocket(4444);
        } catch (IOException e) {
            System.err.println("Could not listen on port: 4444.");
            System.exit(-1);
        }

        while (listening)
        new MultiServerThread(serverSocket.accept()).start();

        serverSocket.close();
    }
}




import java.net.*;
import java.io.*;

public class MultiServerThread extends Thread {
    private Socket socket = null;
public MultiServerThread(Socket socket) {
super("MultiServerThread");
this.socket = socket;
}

public void run() {

try {
    PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
    BufferedReader in = new BufferedReader(
                new InputStreamReader(
                socket.getInputStream()));

    String inputLine, outputLine;
    KnockKnockProtocol kkp = new KnockKnockProtocol();
    outputLine = kkp.processInput(null);
    out.println(outputLine);

    while ((inputLine = in.readLine()) != null) {
    outputLine = kkp.processInput(inputLine);
    out.println(outputLine);
    if (outputLine.equals("Bye"))
        break;
    }
    out.close();
    in.close();
    socket.close();

} catch (IOException e) {
    e.printStackTrace();
}
}

}

您将实现处理您的请求的逻辑:

KnockKnockProtocol kkp = new KnockKnockProtocol();
outputLine = kkp.processInput(null);

您可以通过将线程放在线程池中来优化您的代码,这样您就不需要每次都创建一个新线程。

以下部分是主观的,取决于请求的类型以及您对每个请求的处理方式。 如果您有很多并发的客户端请求,那么 NIO 是您的最佳选择。
如果您的请求很短并且有超过 10 个并发请求,请创建一个池。
如果您的请求超过 100,那么我将开始关注 NIO。

【讨论】:

    【解决方案2】:

    您还可以考虑Netty 和Java NIO。有不止一种方法可以做到这一点。

    【讨论】:

      【解决方案3】:

      Sun's classic Java tutorial 包含一个关于programming with sockets 的部分,该部分将引导您完成an example,这与您尝试编写的程序非常相似。

      【讨论】:

        【解决方案4】:

        Web 服务器只不过是一个带有消息传递功能的美化套接字服务器。自从建立第一个网络连接以来,技术就一直存在。大约一年半前,我有一个项目,与您尝试做的类似。 Java NIO 是最好的选择,它具有连接和线程池以及 Web 服务器所需的所有高级功能,但它有点复杂。如果您想要一个非常好的基线,请查看http://www.quickserver.org/ 我编写的系统是基于此的,它现在可以在我上次听说的一台服务器上处理大约 45,000 台设备。

        【讨论】:

        • Java NIO 没有有'连接和线程池',最好的起点是 java.net。
        猜你喜欢
        • 1970-01-01
        • 1970-01-01
        • 2018-04-28
        • 2021-04-20
        • 2017-01-27
        • 2014-01-06
        • 1970-01-01
        • 1970-01-01
        • 1970-01-01
        相关资源
        最近更新 更多