Http请求超时的一种处理方法[通俗易懂]

Http请求超时的一种处理方法[通俗易懂]URLConnection类常见的超时处理就是调用其setConnectTimeout和setReadTimeout方法:setConnectTimeout:设置连接主机超时(单位:毫秒)setRea

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺

URLConnection类常见的超时处理就是调用其setConnectTimeout和setReadTimeout方法:

  1. setConnectTimeout:设置连接主机超时(单位:毫秒)  
  2. setReadTimeout:设置从主机读取数据超时(单位:毫秒)

还有一种比较另类的就是利用java Object对象的wait()和notify()、notifyAll()方法,利用线程的等待和通知机制处理urlConnection的超时,下面直接贴代码:

public class HttpConnProcessThread implements Runnable {

    public boolean isStop = false;

    public boolean readOK = false;

    private HttpURLConnection reqConnection = null;
    
    public Thread readingThread;

    private int readLen;

    private String msg = null;
        
    private String reqMethod;

    private byte[] data;
    
    /**
     * ReadThread constructor comment.
     */
    public HttpConnProcessThread(HttpURLConnection reqConnection, String msg, String reqMethod ) {
        super();
        this.reqConnection = reqConnection;
        this.msg = msg;
        this.reqMethod = reqMethod;
    }

    public void run() {

        InputStream input = null;
        OutputStream output = null;

        try{
            //reqConnection.connect();
            output = reqConnection.getOutputStream();
            if ("post".equalsIgnoreCase(reqMethod) && msg != null && msg.length() >0) 
            {
                output.write(msg.getBytes());
                output.close();
                output = null;
            }

            // 处理HTTP响应的返回状态信息
            int responseCode = reqConnection.getResponseCode();// 响应的代码if( responseCode != 200 )
                System.out.println("connect failed! responseCode = " + responseCode + " msg=" + reqConnection.getResponseMessage());
            
            input = reqConnection.getInputStream();

            int len;
            byte[] buf = new byte[2048];
            readLen = 0;
            ByteArrayOutputStream outStream = new ByteArrayOutputStream();  
       // 读取inputStream
            while (!isStop) 
            {
                len = input.read(buf);
                if (len <= 0) 
                {
                    this.readOK = true;
                    input.close();
                    data=outStream.toByteArray();
                    break;
                }
                outStream.write(buf, 0, len);  
                readLen += len;
            }
        }
        catch( IOException ie)
        {}
        catch(Exception e)
        {}
        finally
        {
            try{
                reqConnection.disconnect();
                if( input != null )
                    input.close();
                if( output != null )
                    output.close();
                
                //唤醒线程,跳出等待
                wakeUp();
            }catch(Exception e)
            {
                
            }
        }
    }

    public String getMessage(){
        if (!readOK) //超时
        {
            return "";
        }
        
        if (readLen <= 0) {
            return "";
        }
        return new String(data, 0, readLen);
    }

    public void startUp() {
        this.readingThread = new Thread(this);
        readingThread.start();
    }


    //唤醒线程,不再等待
    private synchronized void wakeUp() {
        notifyAll();
    }

    public synchronized void waitForData(int timeout) 
    {
        try {
            //指定超时时间,等待connection响应
            wait(timeout);
        } 
        catch (Exception e) 
        {
        }
            
        if (!readOK)
        {
            isStop = true;
            try{
                //中断线程
                if( readingThread.isAlive() )
                    readingThread.interrupt();
            }catch(Exception e)
            {
                
            }
        }
    }

    public static main(String[] args){
        String msg="";
        URL reqUrl = new URL("http://127.0.0.1:8080/");

        // 建立URLConnection连接
        reqConnection = (HttpURLConnection) reqUrl.openConnection();
        HttpConnProcessThread rec = new HttpConnProcessThread(reqConnection, msg, "post" );
        rec.startUp();
   // 如果顺利连接到并读完数据,则跳出等待,否则等待超时 rec.waitForData(
2000); String retMessage = rec.getMessage(); } }

 

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/167426.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • PyCharm设置改变字体大小的快捷键

    PyCharm设置改变字体大小的快捷键File->Settings在搜索框搜索increase点击IncreaseFontSize(增大字体)右键选择AddMouseShortcut然后按Ctrl并且鼠标滚轮往上滚。同理可以设置减小字体【设置减小字体时,在搜索框内输入decrease】转载于:https://www.cnblogs.com/Will-guo/p/6308991.h…

  • UIControl-IOS开发

    UIControl-IOS开发

  • Nginx实战之反向代理WebSocket的配置实例

    Nginx实战之反向代理WebSocket的配置实例

    2021年10月14日
  • ES6 模板字符串用法

    ES6 模板字符串用法解决字符串拼接问题使用模板字符串,可以省去‘+’拼接的操作,反引号“之间的视为一个整体view:<pv-html=”getHtml()”></p>method:getHtml(){leth1=`<h1>这是一个h1元素内容</h1>`returnh1}结果:通过表达式拼接对象属性使用${}表达式可以直接拼接对象属性的值:letuser={

  • js向数组指定位置添加元素[通俗易懂]

    js向数组指定位置添加元素[通俗易懂]一、JavaScriptsplice()方法splice()方法向/从数组中添加/删除项目,然后返回被删除的项目。方法实例//在数组指定位置插入varfruits=[“Banana”,”Orange”,”Apple”,”Mango”];fruits.splice(2,0,”Lemon”,”Kiwi”);//输出结果//Banana,Orange…

  • 安卓四大组件面试题_android常见面试题

    安卓四大组件面试题_android常见面试题1、Activity与Fragment之间常见的几种通信方式答:1.使用Bundle:在activity中建一个bundle,把要传的值存入bundle,然后通过fragment的setArguments(bundle)传到fragment,在fragment中,用getArguments接收。这个方法能保证在fragment销毁重建后依然能获取到传递过来的数据。2.采用接口回调的方式。3.EventBus。2.谈谈Android中几种LaunchMode的特点和应用场景?

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号