我得到java.net.SocketException：连接重置由对等：socket写错误，当执行类截图中的主函数时

Question

帮助解决方案或哪里出了问题是徒劳的

import java.io.*;
import java.util.*;
import java.awt.image.*;
import java.awt.*;
import java.awt.event.*;
public class screenshot
{
    public static void main(){
        Link l=new Link("localhost",1111);
        System.out.println(Link.getIpAddress());
        String s[]=its();
        for(int i=0;i<s.length;i++){
            l.send(s[i]);//l.send("hello22");
        }
        for(int i=0;i<s.length;i++){
            System.out.println(l.recieve());
        }

        //System.out.println(l.recieve());
    }

    public static String[] its(){
        String[] tbo=null;
        try{
            Robot r=new Robot();
            BufferedImage img=r.createScreenCapture(new Rectangle(Toolkit.getDefaultToolkit().getScreenSize()));
            System.out.println(img.getWidth()+" "+img.getHeight());
            tbo=new String[img.getWidth()];
            for(int i=0;i<tbo.length;i++){
                tbo[i]="";
            }
            for(int i=0;i<img.getWidth();i++){
                for(int j=0;j<img.getHeight();j++){
                    tbo[i]+=img.getRGB(i,j);//out+=img.getRGB(i,j);
                }
                System.out.println(i);
                //out+="b";
            }
            //for(int i=0;i<img.getWidth();i++){
            //    out+=tbo[i]+"\n";
            //}
        }catch(Exception e){}
        //Base bo=new Base("1234567890-\n");
        //Base bn=new Base("1234567890qwertyuiopasdfghjklzxcvbnmQWERTYUIOPASDFGHJKLZXCVBNM");
        //BaseNumber bnum=new BaseNumber(out,bo);
        //out=bnum.valueAs(bn).toString();
        return tbo;
    }

    public static void main2(){
        System.out.println(its());
    }
}

在这种情况下创建要发送到localhost的链接对象的Link类

class Link
{
    final public String ip;final public int port;Listener l;
    //protected ArrayList<String> queue=new ArrayList<String>();
    public Link(String ip,int port)
    {
        this.ip=ip;
        this.port=port;
        this.l=new Listener(port);
        l.start();
    }

    public static String getIpAddress(){
        try{
            return InetAddress.getLocalHost().getHostAddress();
        }catch(Exception e){
            System.out.println("An error ocurrerd in getIp\n "+e);
            System.exit(0);
            return null;
        }
    }

    public void send(String st)
    {
        try{      
            Socket s=new Socket(ip,port);  
            DataOutputStream dout=new DataOutputStream(s.getOutputStream()); 
            dout.writeUTF(st);  
            dout.flush();  
            dout.close();  
            s.close();  
        }catch(Exception e){
            System.out.println("An error ocurrerd in send\n "+e);
            e.printStackTrace();
            System.exit(0);
        }
    }

    public String recieve(){
        while(l.queue.size()==0);
        String s=l.queue.get(0);
        l.queue.remove(0);
        return s;
    }
}
class Listener extends Thread{
    ArrayList<String> queue=new ArrayList<String>();int port;
    Listener(int port){
        this.port=port;
    }
    public void run(){
        try{  
            while(true){
                ServerSocket ss=new ServerSocket(port);  
                Socket s=ss.accept();
                DataInputStream dis=new DataInputStream(s.getInputStream());  
                String str=(String)dis.readUTF();  
                queue.add(str);
                ss.close();
            }
        }catch(Exception e){
            System.out.println("An error ocurrerd in recieve\n "+e);
            System.exit(0);

        }

    }
}

Answer 1

while(true){
            ServerSocket ss=new ServerSocket(port);  
            Socket s=ss.accept();
            DataInputStream dis=new DataInputStream(s.getInputStream());  
            String str=(String)dis.readUTF();  
            queue.add(str);
            ss.close();
        }

理想情况下，您应该在while循环外创建并关闭一个套接字，然后在while循环内读取。

与Send类似，您不应该在每次必须发送时都创建套接字。如果必须这样做，那么服务器在while循环中也必须有accept（）。

希望这能解决你的问题。