文档章节

根据API获取头条新闻

 奋斗1221
发布于 2017/05/11 15:49
字数 639
阅读 52
收藏 0

import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLEncoder;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;


import java.util.UUID;

import org.jeecgframework.web.system.service.SystemService;
import org.junit.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.TestExecutionListeners;

import com.alibaba.fastjson.JSONArray;
import com.jeecg.toutiao.entity.ToutiaosEntity;
import com.jeecg.toutiao.service.ToutiaoServiceI;
import com.jeecg.toutiao.service.impl.ToutiaoServiceImpl;
import com.mysql.jdbc.Connection;
import com.mysql.jdbc.PreparedStatement;

import net.sf.json.JSONObject;

public class ApiUtils extends Thread{
    public static final String DEF_CHATSET = "UTF-8";
    public static final int DEF_CONN_TIMEOUT = 30000;
    public static final int DEF_READ_TIMEOUT = 30000;
    public static String userAgent =  "Mozilla/5.0 (Windows NT 6.1) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/29.0.1547.66 Safari/537.36";
    public  static java.sql.Connection conn;
    public static PreparedStatement ps;
    //配置您申请的KEY
    public static final String APPKEY ="";
    
    
     
    
    
    public void run(){
        
        
        getNews();
        
        
        
    }
    
 
    //2.请求头条消息查询接口
    
    public static List<ToutiaosEntity> getNews(){
        String result =null;
        String url ="http://v.juhe.cn/toutiao/index";//请求接口地址
        Map params = new HashMap();//请求参数
        params.put("type", "&");
        params.put("key", "31330e24d1b28367263e39dd7a6832a8");
        ToutiaosEntity toutiaosEntity = new ToutiaosEntity();
        List<ToutiaosEntity> lists = new ArrayList<ToutiaosEntity>();
       
        try {
            result =net(url, params, "GET");
            JSONObject object = JSONObject.fromObject(result);
            if(object.getInt("error_code")==0){
                System.out.println(object.get("result"));
                JSONObject objectS = JSONObject.fromObject(object.get("result"));
                System.out.println(objectS.get("data"));
              
                net.sf.json.JSONArray  jsonArray = (net.sf.json.JSONArray) objectS.get("data");
                
                 
             System.out.println("--" + jsonArray.size());
             for (int i = 0; i < jsonArray.size(); i++) {
                 String categorys = jsonArray.getString(i);
                
                 JSONObject  totalData = JSONObject.fromObject(categorys);
                 
                 String category = (String) totalData.get("category");
                 String title = (String) totalData.get("title");
                 String thumbnailPicS2 = (String) totalData.get("thumbnail_pic_s02");
                 String thumbnailPicS3 = (String) totalData.get("thumbnail_pic_s03");
                 String uniquekey = (String) totalData.get("uniquekey");
                 String authorName = (String) totalData.get("authorName");
                 String newsDate =  (String) totalData.get("newsDate");
                 String newsUrl = (String) totalData.get("url");
                 String thumbnailPicS = (String) totalData.get("thumbnail_pic_s");
                 UUID id =  UUID.randomUUID();
                 toutiaosEntity.setId(id.toString());
                 toutiaosEntity.setAuthorName(authorName);
                 toutiaosEntity.setCategory(category);
                 toutiaosEntity.setNewsDate(newsDate);
                 toutiaosEntity.setThumbnailPicS(thumbnailPicS);
                 toutiaosEntity.setThumbnailPicS2(thumbnailPicS2);
                 toutiaosEntity.setThumbnailPicS3(thumbnailPicS3);
                 toutiaosEntity.setTitle(title);
                 toutiaosEntity.setUniquekey(uniquekey);
                 toutiaosEntity.setUrl(newsUrl);
                 lists.add(toutiaosEntity);
                 String sql = "insert into toutiao (id,category,title,THUMBNAIL_PIC_S2,THUMBNAIL_PIC_S3,uniquekey,AUTHOR_NAME,NEWS_DATE,url,THUMBNAIL_PIC_S) values(?,?,?,?,?,?,?,?,?,?)";
                 conn=getConnection();
                 ps = (PreparedStatement) conn.prepareStatement(sql);
                 ps.setString(1, toutiaosEntity.getId());
                 ps.setString(2, toutiaosEntity.getCategory());
                 ps.setString(3, toutiaosEntity.getTitle());
                 if(toutiaosEntity.getThumbnailPicS2() != null){
                 ps.setString(4, toutiaosEntity.getThumbnailPicS2());
                 ps.setString(5, toutiaosEntity.getThumbnailPicS3());
                 }
                 else{
                 ps.setString(4, "");
                 ps.setString(5, "");
                 }
                 ps.setString(6, toutiaosEntity.getUniquekey());
                 ps.setString(7, toutiaosEntity.getAuthorName());
                 ps.setString(8, toutiaosEntity.getNewsDate());
                 ps.setString(9, toutiaosEntity.getUrl());
                 ps.setString(10, toutiaosEntity.getThumbnailPicS());
                 ps.executeUpdate();
               
                ps.close();
                conn.close();
                 
            }
             //插入数据库
             
            }else{
                System.out.println(object.get("error_code")+":"+object.get("reason"));
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return lists;
    }
 
  
 
 
   
        public static java.sql.Connection getConnection(){
            String url="jdbc:mysql://localhost:3306/jeecg";
            String userName="root";
            String password="111111";
            try {
                Class.forName("com.mysql.jdbc.Driver");
            } catch (ClassNotFoundException e) {
               
                System.out.println("找不到驱动!");
                e.printStackTrace();
            }
            try {
                conn = DriverManager.getConnection(url, userName, password);
                if(conn!=null){
                    System.out.println("connection successful");
                }
            } catch (SQLException e) {
              
                    System.out.println( "connection fail");
                e.printStackTrace();
            }
            return conn;
        };
    


    public static void main(String[] args) {
        
    
     ApiUtils api = new ApiUtils();
     api.start();
    }
 
    /**
     *
     * @param strUrl 请求地址
     * @param params 请求参数
     * @param method 请求方法
     * @return  网络请求字符串
     * @throws Exception
     */
    public static String net(String strUrl, Map params,String method) throws Exception {
        HttpURLConnection conn = null;
        BufferedReader reader = null;
        String rs = null;
        try {
            StringBuffer sb = new StringBuffer();
            if(method==null || method.equals("GET")){
                strUrl = strUrl+"?"+urlencode(params);
            }
            URL url = new URL(strUrl);
            conn = (HttpURLConnection) url.openConnection();
            if(method==null || method.equals("GET")){
                conn.setRequestMethod("GET");
            }else{
                conn.setRequestMethod("POST");
                conn.setDoOutput(true);
            }
            conn.setRequestProperty("User-agent", userAgent);
            conn.setUseCaches(false);
            conn.setConnectTimeout(DEF_CONN_TIMEOUT);
            conn.setReadTimeout(DEF_READ_TIMEOUT);
            conn.setInstanceFollowRedirects(false);
            conn.connect();
            if (params!= null && method.equals("POST")) {
                try {
                    DataOutputStream out = new DataOutputStream(conn.getOutputStream());
                        out.writeBytes(urlencode(params));
                } catch (Exception e) {
                    // TODO: handle exception
                }
            }
            InputStream is = conn.getInputStream();
            reader = new BufferedReader(new InputStreamReader(is, DEF_CHATSET));
            String strRead = null;
            while ((strRead = reader.readLine()) != null) {
                sb.append(strRead);
            }
            rs = sb.toString();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if (reader != null) {
                reader.close();
            }
            if (conn != null) {
                conn.disconnect();
            }
        }
        return rs;
    }
 
    //将map型转为请求参数型
    public static String urlencode(Map<String,Object>data) {
        StringBuilder sb = new StringBuilder();
        for (Map.Entry i : data.entrySet()) {
            try {
                sb.append(i.getKey()).append("=").append(URLEncoder.encode(i.getValue()+"","UTF-8")).append("&");
            } catch (UnsupportedEncodingException e) {
                e.printStackTrace();
            }
        }
        return sb.toString();
    }
}
 

© 著作权归作者所有

粉丝 1
博文 84
码字总数 81151
作品 0
太原
程序员
私信 提问
Clinews:从命令行阅读新闻和最新头条

不久前,我们写了一个名为 InstantNews 的命令行新闻客户端,它可以帮助你立即在命令行阅读新闻和最新头条新闻。今天,我偶然发现了一个名为 Clinews 的类似,它的其功能与此相同 —— 在终端...

作者: Sk
2018/10/11
0
0
谷歌智能助理推出「正能量新闻推送」功能,帮助用户不那么沮丧…

简评:Google 最近推出一项「good news」的实验性功能,通过 Google Assistant,用户可以要求 Google 推送一些好消息和正面新闻,用来缓解接收过多坏消息的心情。虽然最近的时事新闻都负能量...

极光推送
2018/09/07
13
0
Appstore排名前十的程序员应用软件

程序员又名程序猿,苦逼劳累的代名词,曾经一个朋友这么开玩笑说,如果你是富二代,你当程序员就是脑残,如果你是穷二代,当程序员的话,死的时候一定是趴键盘。 程序员   哦,可怜的程序员...

程序员客栈
2016/05/14
4.9K
1
ecit0086/Node-SpliderApi

SpliderApi 基于Node+express 的一个网络爬虫 API接口 包括前端开发日报、知乎日报、前端top框架排行、妹纸福利、搞笑视频、各类视频新闻资讯 热点详情接口数 接口文档使用的是 $docsify 生成...

ecit0086
2017/07/15
0
0
Android 抓取指定网页数据并显示

需求:想设计一个应用,可以获取指定网页的数据(数据要筛选出来),然后可以将数据分享到微博或者qq上,而且自动更新,类似于那些“头条新闻”的应用程序。 本人初学,实在太菜了,求一个思...

lala1
2013/08/15
1K
0

没有更多内容

加载失败,请刷新页面

加载更多

spring cloud

一、从面试题入手 1.1、什么事微服务 1.2、微服务之间如何独立通讯的 1.3、springCloud和Dubbo有哪些区别 1.通信机制:DUbbo基于RPC远程过程调用;微服务cloud基于http restFUL API 1.4、spr...

榴莲黑芝麻糊
49分钟前
2
0
Executor线程池原理与源码解读

线程池为线程生命周期的开销和资源不足问题提供了解决方 案。通过对多个任务重用线程,线程创建的开销被分摊到了多个任务上。 线程实现方式 Thread、Runnable、Callable //实现Runnable接口的...

小强的进阶之路
昨天
6
0
maven 环境隔离

解决问题 即 在 resource 文件夹下面 ,新增对应的资源配置文件夹,对应 开发,测试,生产的不同的配置内容 <resources> <resource> <directory>src/main/resources.${deplo......

之渊
昨天
8
0
详解箭头函数和普通函数的区别以及箭头函数的注意事项、不适用场景

箭头函数是ES6的API,相信很多人都知道,因为其语法上相对于普通函数更简洁,深受大家的喜爱。就是这种我们日常开发中一直在使用的API,大部分同学却对它的了解程度还是不够深... 普通函数和...

OBKoro1
昨天
7
0
轻量级 HTTP(s) 代理 TinyProxy

CentOS 下安装 TinyProxy yum install -y tinyproxy 启动、停止、重启 # 启动service tinyproxy start# 停止service tinyproxy stop# 重启service tinyproxy restart 相关配置 默认...

Anoyi
昨天
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部