如何用java实现HTTP长连接

Python011

如何用java实现HTTP长连接,第1张

tomcat9提供了一种叫webSocket的东西，可以实现这个，但是必须要使用tomcat9来支持

另外一个就是运用长轮询，就是前台给后台发一个请求, 然后后台一直不处理, 可以while循环或者sleep(1000), 每隔1秒去检查是否应该返回数据, 如果后台决定要刷新了, 就返回数据, 然后前台接收到返回数据后去刷新你要刷新的东西, 刷新完毕后如果需要, 再次发送这个请求。当然，为了不阻塞其它的ajax请求, 长轮询一般放在一个单独的iframe里

import java.io.BufferedReader  

import java.io.DataOutputStream  

import java.io.InputStreamReader  

import java.net.HttpURLConnection  

import java.net.URL  

import java.net.URLEncoder  

  

public class DemoTest1 {  

  

    public static final String GET_URL = "http://112.4.27.9/mall-back/if_user/store_list?storeId=32"  

//    public static final String POST_URL = "http://112.4.27.9/mall-back/if_user/store_list"  

    // 妙兜测试接口  

    public static final String POST_URL = "http://121.40.204.191:8180/mdserver/service/installLock"  

      

    /** 

     * 接口调用 GET 

     */  

    public static void httpURLConectionGET() {  

        try {  

            URL url = new URL(GET_URL)    // 把字符串转换为URL请求地址  

            HttpURLConnection connection = (HttpURLConnection) url.openConnection()// 打开连接  

            connection.connect()// 连接会话  

            // 获取输入流  

            BufferedReader br = new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8"))  

            String line  

            StringBuilder sb = new StringBuilder()  

            while ((line = br.readLine()) != null) {// 循环读取流  

                sb.append(line)  

            }  

            br.close()// 关闭流  

            connection.disconnect()// 断开连接  

            System.out.println(sb.toString())  

        } catch (Exception e) {  

            e.printStackTrace()  

            System.out.println("失败!")  

        }  

    }  

      

    /** 

     * 接口调用  POST 

     */  

    public static void httpURLConnectionPOST () {  

        try {  

            URL url = new URL(POST_URL)  

              

            // 将url 以 open方法返回的urlConnection  连接强转为HttpURLConnection连接  (标识一个url所引用的远程对象连接)  

            HttpURLConnection connection = (HttpURLConnection) url.openConnection()// 此时cnnection只是为一个连接对象,待连接中  

              

            // 设置连接输出流为true,默认false (post 请求是以流的方式隐式的传递参数)  

            connection.setDoOutput(true)  

              

            // 设置连接输入流为true  

            connection.setDoInput(true)  

              

            // 设置请求方式为post  

            connection.setRequestMethod("POST")  

              

            // post请求缓存设为false  

            connection.setUseCaches(false)  

              

            // 设置该HttpURLConnection实例是否自动执行重定向  

            connection.setInstanceFollowRedirects(true)  

              

            // 设置请求头里面的各个属性 (以下为设置内容的类型,设置为经过urlEncoded编码过的from参数)  

            // application/x-javascript text/xml->xml数据 application/x-javascript->json对象 application/x-www-form-urlencoded->表单数据  

            // charset=utf-8 必须要，不然妙兜那边会出现乱码【★★★★★】  

            connection.setRequestProperty("Content-Type", "application/x-www-form-urlencodedcharset=utf-8")     

              

            // 建立连接 (请求未开始,直到connection.getInputStream()方法调用时才发起,以上各个参数设置需在此方法之前进行)  

            connection.connect()  

              

            // 创建输入输出流,用于往连接里面输出携带的参数,(输出内容为?后面的内容)  

            DataOutputStream dataout = new DataOutputStream(connection.getOutputStream())  

              

            String app_key = "app_key="+ URLEncoder.encode("4f7bf8c8260124e6e9c6bf094951a111", "utf-8")        // 已修改【改为错误数据，以免信息泄露】  

            String agt_num = "&agt_num="+ URLEncoder.encode("10111", "utf-8")              // 已修改【改为错误数据，以免信息泄露】  

            String pid = "&pid="+ URLEncoder.encode("BLZXA150401111", "utf-8")             // 已修改【改为错误数据，以免信息泄露】  

            String departid = "&departid="+ URLEncoder.encode("10007111", "utf-8")         // 已修改【改为错误数据，以免信息泄露】  

            String install_lock_name = "&install_lock_name="+ URLEncoder.encode("南天大门", "utf-8")  

            String install_address = "&install_address="+ URLEncoder.encode("北京育新", "utf-8")  

            String install_gps = "&install_gps="+ URLEncoder.encode("116.350888,40.011001", "utf-8")  

            String install_work = "&install_work="+ URLEncoder.encode("小李", "utf-8")  

            String install_telete = "&install_telete="+ URLEncoder.encode("13000000000", "utf-8")  

            String intall_comm = "&intall_comm="+ URLEncoder.encode("一切正常", "utf-8")  

              

            // 格式 parm = aaa=111&bbb=222&ccc=333&ddd=444  

            String parm = app_key+ agt_num+ pid+ departid+ install_lock_name+ install_address+ install_gps+ install_work+ install_telete+ intall_comm  

              

            // 将参数输出到连接  

            dataout.writeBytes(parm)  

              

            // 输出完成后刷新并关闭流  

            dataout.flush()  

            dataout.close() // 重要且易忽略步骤 (关闭流,切记!)   

              

//            System.out.println(connection.getResponseCode())  

              

            // 连接发起请求,处理服务器响应  (从连接获取到输入流并包装为bufferedReader)  

            BufferedReader bf = new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8"))   

            String line  

            StringBuilder sb = new StringBuilder() // 用来存储响应数据  

              

            // 循环读取流,若不到结尾处  

            while ((line = bf.readLine()) != null) {  

//                sb.append(bf.readLine())  

                sb.append(line).append(System.getProperty("line.separator"))  

            }  

            bf.close()    // 重要且易忽略步骤 (关闭流,切记!)   

            connection.disconnect() // 销毁连接  

            System.out.println(sb.toString())  

      

        } catch (Exception e) {  

            e.printStackTrace()  

        }  

    }  

      

    public static void main(String[] args) {  

//        httpURLConectionGET()  

        httpURLConnectionPOST()  

    }  

}

1.写http请求方法

[java] view plain copy

//处理http请求 requestUrl为请求地址 requestMethod请求方式，值为"GET"或"POST"

public static String httpRequest(String requestUrl,String requestMethod,String outputStr){

StringBuffer buffer=null

try{

URL url=new URL(requestUrl)

HttpURLConnection conn=(HttpURLConnection)url.openConnection()

conn.setDoOutput(true)

conn.setDoInput(true)

conn.setRequestMethod(requestMethod)

conn.connect()

//往服务器端写内容 也就是发起http请求需要带的参数

if(null!=outputStr){

OutputStream os=conn.getOutputStream()

os.write(outputStr.getBytes("utf-8"))

os.close()

}

//读取服务器端返回的内容

InputStream is=conn.getInputStream()

InputStreamReader isr=new InputStreamReader(is,"utf-8")

BufferedReader br=new BufferedReader(isr)

buffer=new StringBuffer()

String line=null

while((line=br.readLine())!=null){

buffer.append(line)

}

}catch(Exception e){

e.printStackTrace()

}

return buffer.toString()

}

2.测试。

[java] view plain copy

public static void main(String[] args){

String s=httpRequest("http://www.qq.com","GET",null)

System.out.println(s)

}

输出结果为www.qq.com的源代码，说明请求成功。

注：1).第一个参数url需要写全地址，即前边的http必须写上，不能只写www.qq.com这样的。

2).第二个参数是请求方式，一般接口调用会给出URL和请求方式说明。

3).第三个参数是我们在发起请求的时候传递参数到所要请求的服务器，要传递的参数也要看接口文档确定格式，一般是封装成json或xml.

4).返回内容是String类，但是一般是有格式的json或者xml。

二：发起https请求。

1.https是对链接加了安全证书SSL的，如果服务器中没有相关链接的SSL证书，它就不能够信任那个链接，也就不会访问到了。所以我们第一步是自定义一个信任管理器。自要实现自带的X509TrustManager接口就可以了。

[java] view plain copy

import java.security.cert.CertificateException

import java.security.cert.X509Certificate

import javax.net.ssl.X509TrustManager

public class MyX509TrustManager implements X509TrustManager {

@Override

public void checkClientTrusted(X509Certificate[] chain, String authType)

throws CertificateException {

// TODO Auto-generated method stub

}

@Override

public void checkServerTrusted(X509Certificate[] chain, String authType)

throws CertificateException {

// TODO Auto-generated method stub

}

@Override

public X509Certificate[] getAcceptedIssuers() {

// TODO Auto-generated method stub

return null

}

}

注：1)需要的包都是java自带的，所以不用引入额外的包。

2.)可以看到里面的方法都是空的，当方法为空是默认为所有的链接都为安全，也就是所有的链接都能够访问到。当然这样有一定的安全风险，可以根据实际需要写入内容。

2.编写https请求方法。

[java] view plain copy

/*

* 处理https GET/POST请求

* 请求地址、请求方法、参数

* */

public static String httpsRequest(String requestUrl,String requestMethod,String outputStr){

StringBuffer buffer=null

try{

//创建SSLContext

SSLContext sslContext=SSLContext.getInstance("SSL")

TrustManager[] tm={new MyX509TrustManager()}

//初始化

sslContext.init(null, tm, new java.security.SecureRandom())

//获取SSLSocketFactory对象

SSLSocketFactory ssf=sslContext.getSocketFactory()

URL url=new URL(requestUrl)

HttpsURLConnection conn=(HttpsURLConnection)url.openConnection()

conn.setDoOutput(true)

conn.setDoInput(true)

conn.setUseCaches(false)

conn.setRequestMethod(requestMethod)

//设置当前实例使用的SSLSoctetFactory

conn.setSSLSocketFactory(ssf)

conn.connect()

//往服务器端写内容

if(null!=outputStr){

OutputStream os=conn.getOutputStream()

os.write(outputStr.getBytes("utf-8"))

os.close()

}

//读取服务器端返回的内容

InputStream is=conn.getInputStream()

InputStreamReader isr=new InputStreamReader(is,"utf-8")

BufferedReader br=new BufferedReader(isr)

buffer=new StringBuffer()

String line=null

while((line=br.readLine())!=null){

buffer.append(line)

}

}catch(Exception e){

e.printStackTrace()

}

return buffer.toString()

}

可见和http访问的方法类似，只是多了SSL的相关处理。

3.测试。先用http请求的方法访问，再用https的请求方法访问，进行对比。

http访问：

[java] view plain copy

public static void main(String[] args){

String s=httpRequest("https://kyfw.12306.cn/","GET",null)

System.out.println(s)

}

结果为：

https访问：

[java] view plain copy

public static void main(String[] args){

String s=httpsRequest("https://kyfw.12306.cn/","GET",null)

System.out.println(s)

}

结果为：

可见https的链接一定要进行SSL的验证或者过滤之后才能够访问。

三：https的另一种访问方式——导入服务端的安全证书。

1.下载需要访问的链接所需要的安全证书。https://kyfw.12306.cn/ 以这个网址为例。

1）在浏览器上访问https://kyfw.12306.cn/。

2）点击上图的那个打了×的锁查看证书。

3）选择复制到文件进行导出，我们把它导入到java项目所使用的jre的lib文件下的security文件夹中去，我的是这个路径。D:\Program Files (x86)\Java\jre8\lib\security

注：中间需要选导出格式，就选默认的就行，还需要命名，我命名的是12306.

2.打开cmd,进入到java项目所使用的jre的lib文件下的security目录。

3.在命令行输入 Keytool -import -alias 12306 -file 12306.cer -keystore cacerts

4.回车后会让输入口令，一般默认是changeit,输入时不显示，输入完直接按回车，会让确认是否信任该证书，输入y，就会提示导入成功。

5.导入成功后就能像请求http一样请求https了。

测试：

[java] view plain copy

public static void main(String[] args){

String s=httpRequest("https://kyfw.12306.cn/","GET",null)

System.out.println(s)

}

结果：

现在就可以用http的方法请求https了。

注：有时候这一步还是会出错，那可能是jre的版本不对，我们右键run as——run configurations,选择证书所在的jre之后再运行。