个人中心
gpt4 book ai didi

java - 简单的客户端/服务器套接字应用程序 SocketException : Connection reset

转载 作者：行者123 更新时间：2023-11-29 09:08:33 25 4
gpt4 key购买 nike

<分区>

所以我正在使用套接字做一个简单的客户端服务器程序。大多数情况下，我从 KnockKnockServer 中获取了代码但是我使用 Threads 实现了客户端(这对我来说是必要的，因为我想稍后在 android 应用程序中使用它)

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

public class HelpMeServer {
public static void main(String[] args) throws IOException {
    Database db=new Database();
    ServerSocket serverSocket = null;
    try {
        serverSocket = new ServerSocket(50000);
        System.out.println("Listening on port 911");
    } catch (IOException e) {
        System.err.println("Could not listen on port: 911.");
        System.exit(1);
    }

    Socket clientSocket = null;
    try {
        clientSocket = serverSocket.accept();
        System.out.println("incomig");
    } catch (IOException e) {
        System.err.println("Accept failed.");
        System.exit(1);
    }
    System.out.println("getting printwriter and bufferedreader");
    PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true);
    BufferedReader in = 
        new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
    String inputLine, outputLine;


    Protocol kkp = new Protocol(db);
    // initiate conversation with client
    System.out.println("listening..");
//Here the exception is thrown.
    while ((inputLine = in.readLine()) != null) {
         kkp.processInput(inputLine);
         //if (outputLine.equals("Bye."))
            //break;
    }        out.close();
    in.close();
    clientSocket.close();
    serverSocket.close();
}
}
import java.net.*;
import java.io.*;

public class Protocol {
private static final int WAITING = 0;
private static final int REGISTERING = 1;
private static final int LOGIN = 2;

private int state = WAITING;
private Database db;
private String email;
private String password;
public Protocol(Database db)
{
    this.db=db;
    email=null;
    password=null;
}
public void processInput(String theInput) {
    System.out.println("Cliet: "+theInput);


    if (state == WAITING) {
        if(theInput.equals("register"))
            {
            state=REGISTERING;
            System.out.println("set state to registering");
            }
        else if(theInput=="login"){
            state=LOGIN;
            System.out.println("set state to registering");
        }
        }


    else if(state == REGISTERING)
    {
        if(email==null) {
            email=theInput;
            System.out.println("set email to "+email);
        }
        else {
            password=theInput;
            System.out.println("saving "+email);
            db.addUser(new String(email), new String(password));
            password=null;
            email=null;
            state=WAITING;
        }
    }
}
}
 import java.io.*;
 import java.net.*;

public class NetworkingThread extends Thread{

Socket kkSocket;
PrintWriter out;
BufferedReader in;
public void run()
    {
    kkSocket = null;
    out = null;
    in = null;

    try {
        kkSocket = new Socket("localhost", 50000);
        out = new PrintWriter(kkSocket.getOutputStream(), true);
        in = new BufferedReader(new InputStreamReader(kkSocket.getInputStream()));
    } catch (UnknownHostException e) {
        System.err.println("Don't know about host: taranis.");
        System.exit(1);
    } catch (IOException e) {
        System.err.println("Couldn't get I/O for the connection to: taranis.");
        System.exit(1);
    }   

}
public void close()
{
    out.close();
    try {
        in.close();
        kkSocket.close();
    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
}
public void write(String s)
{
    out.println(s);  
    out.flush();
}
}

public class go {

/**
 * @param args
 */
public static void main(String[] args) {
        NetworkingThread n=new NetworkingThread();
    n.start();
    n.write("register");
    n.write("a@gmail.com");
    n.write("password");
    n.close();

}

 }

我的错误:

Exception in thread "main" java.net.SocketException: Connection reset
at java.net.SocketInputStream.read(Unknown Source)
at java.net.SocketInputStream.read(Unknown Source)
at sun.nio.cs.StreamDecoder.readBytes(Unknown Source)
at sun.nio.cs.StreamDecoder.implRead(Unknown Source)
at sun.nio.cs.StreamDecoder.read(Unknown Source)
at java.io.InputStreamReader.read(Unknown Source)
at java.io.BufferedReader.fill(Unknown Source)
at java.io.BufferedReader.readLine(Unknown Source)
at java.io.BufferedReader.readLine(Unknown Source)
at HelpMeServer.main(HelpMeServer.java:34)

如果我采用此代码并将其放入 NetworkThread 的运行方法中，我的错误就会消失。但是我不能在我的应用程序中使用它，我必须从外部调用这些方法

n.write("register");
n.write("a@gmail.com");
n.write("password");
n.close();

所以我根据你的建议做了修改(在同一个地方仍然是同样的错误)

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

public class HelpMeServer {
 public static void main(String[] args) throws IOException {
    Database db=new Database();
    ServerSocket serverSocket = null;
    try {
        serverSocket = new ServerSocket(50000);
        System.out.println("Listening on port 911");
    } catch (IOException e) {
        System.err.println("Could not listen on port: 911.");
        System.exit(1);
    }

   while(true)
   {
    Socket clientSocket = null;
    try {
        clientSocket = serverSocket.accept();
        System.out.println("incomig");
        ClientThread t=new ClientThread(clientSocket,db);
        t.start();
    } catch (IOException e) {
        System.err.println("Accept failed.");
        System.exit(1);
    }
   }
  }
          }

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;


public class ClientThread extends Thread {

Socket clientSocket;
Database db;
public ClientThread(Socket s,Database db)
{
    clientSocket=s;
    this.db=db;
}
public void run()
{
     System.out.println("getting printwriter and bufferedreader");
        PrintWriter out;
        try {
        out = new PrintWriter(clientSocket.getOutputStream(), true);
        BufferedReader in = 
        new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
                String inputLine, outputLine;


                Protocol kkp = new Protocol(db);
                System.out.println("listening..");
                while ((inputLine = in.readLine()) != null) {//error!
                     kkp.processInput(inputLine);
                     //if (outputLine.equals("Bye."))
                        //break;
                } 
                out.close();
               in.close();
               clientSocket.close();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

}

  }

25 4 0
文章推荐： java - Java 中 YouTube API 的 NoSuchMethodError
文章推荐： bash - 如何计算文件每一行中的字符数，不包括特定字符列表？
文章推荐： bash - 如何通过在 bash 脚本中输入两次来安全地确认密码
文章推荐： java - 如何使用 Java 连接到 WSDL 服务？
行者123
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
全站热门文章
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com