devbox
酷酷是懒虫
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

实现百度网盘分享保存到自己的网盘_java 转存百度链接

作者：酷酷是懒虫 | 2024-07-10 21:40:23

赞

踩

java 转存百度链接

目录

前言

简介

地址链接

功能

实现百度网盘分享保存到自己的网盘

查看源码的方式出现http地址

java实现解析地址保存到数据库

Python webdriver.Chrome()的使用

Python实现自动分享

前言

本文可以学习了解java file 类操作和python 自动化测试，通过Python webdriver.Chrome()实现百度网盘自动点击分享地址和保存到我的网盘，供个人学习使用，在网上看过很多类似的文章，缺少解析url地址和python版本说明，特此总结

简介

地址链接

这是博主【拓跋阿秀】百度分享的计算机书籍

README.md · forthespada/CS-Books - Gitee.com

功能

实现百度网盘分享保存到自己的网盘

步骤：汇总

1、查看源码的方式出现http地址

2、java实现解析地址保存到数据库

3、Python webdriver.Chrome() 【谷歌驱动】的使用

4、Python实现自动分享

查看源码的方式出现http地址

####  00、C语言
​
- 《C程序设计语言（第二版）》 [百度云链接](https://gitee.com/link?XXX) 提取码：2and
- 《C Primer Plus 中英版》 [百度云链接](https://gitee.com/link?XXX) 提取码：2dox

​

安装typora,下载分享地址链接 点击左下角查看源码或者【ctrl】

将带http地址保存到桌面【C:\Users\Administrator\Desktop\temp.txt】

java实现解析地址保存到数据库

FileUtils.java

  1. package com.bridge.file;
  2. ​
  3. import com.bridge.NetDiskUrl;
  4. import com.bridge.jdbc.JDBCUtils;
  5. import org.springframework.util.StringUtils;
  6. ​
  7. import java.io.BufferedReader;
  8. import java.io.File;
  9. import java.io.FileInputStream;
  10. import java.io.InputStreamReader;
  11. import java.util.ArrayList;
  12. import java.util.List;
  13. import java.util.regex.Matcher;
  14. import java.util.regex.Pattern;
  15. ​
  16. public class FileUtils {
  17. ​
  18.     private static String title = "";
  19.     private static String subTitle = "";
  20. ​
  21.     public static void readText() throws Exception {
  22.         File file = new File("C:\\Users\\Administrator\\Desktop\\temp.txt");
  23.         FileInputStream fis = new FileInputStream(file);
  24.         //Construct BufferedReader from InputStreamReader
  25.         BufferedReader br = new BufferedReader(new InputStreamReader(fis));
  26.         String line = null;
  27.         List<NetDiskUrl> list = new ArrayList<>();
  28.         while ((line = br.readLine()) != null) {
  29.             NetDiskUrl netDiskUrl = extractUrls(line);
  30.             if (netDiskUrl != null) {
  31.                 list.add(netDiskUrl);
  32. //                System.out.println(netDiskUrl.toString());
  33.             }
  34.         }
  35.         br.close();
  36.         JDBCUtils.batchCommitInsert(list);
  37.     }
  38. ​
  39.     public static NetDiskUrl extractUrls(String input) {
  40.         if (!StringUtils.hasText(input)) {
  41.             return null;
  42.         }
  43.         input = input.trim();
  44.         if (input.startsWith("####") && !input.startsWith("#####")) {
  45.             if (input.contains("、")) {
  46.                 String[] split = input.split("、");
  47.                 title = split[1];
  48.                 subTitle = "";
  49.             }
  50.         }
  51.         if (input.startsWith("#####")) {
  52.             if (input.contains("、")) {
  53.                 String[] split = input.split("、");
  54.                 subTitle = split[1];
  55.             }
  56.         }
  57. ​
  58.         String code = "";
  59.         if (input.contains("提取码")) {
  60.             code = input.substring(input.length() - 4);
  61.         }
  62. ​
  63.         // 提前http地址
  64.         Pattern pattern = Pattern.compile(
  65.                 "\\b(((ht|f)tp(s?)\\:\\/\\/|~\\/|\\/)|www.)" +
  66.                         "(\\w+:\\w+@)?(([-\\w]+\\.)+(com|org|net|gov" +
  67.                         "|mil|biz|info|mobi|name|aero|jobs|museum" +
  68.                         "|travel|[a-z]{2}))(:[\\d]{1,5})?" +
  69.                         "(((\\/([-\\w~!$+|.,=]|%[a-f\\d]{2})+)+|\\/)+|\\?|#)?" +
  70.                         "((\\?([-\\w~!$+|.,*:]|%[a-f\\d{2}])+=?" +
  71.                         "([-\\w~!$+|.,*:=]|%[a-f\\d]{2})*)" +
  72.                         "(&(?:[-\\w~!$+|.,*:]|%[a-f\\d{2}])+=?" +
  73.                         "([-\\w~!$+|.,*:=]|%[a-f\\d]{2})*)*)*" +
  74.                         "(#([-\\w~!$+|.,*:=]|%[a-f\\d]{2})*)?\\b");
  75.         Matcher matcher = pattern.matcher(input);
  76.         if (matcher.find()) {
  77.             NetDiskUrl netDiskUrl = new NetDiskUrl();
  78.             netDiskUrl.setTitle(title);
  79.             netDiskUrl.setSubTitle(subTitle);
  80.             netDiskUrl.setUrl(matcher.group());
  81.             netDiskUrl.setCode(code);
  82.             return netDiskUrl;
  83.         }
  84.         return null;
  85.     }
  86. ​
  87.     public static void main(String[] args) {
  88.         try {
  89.             FileUtils.readText();
  90.         } catch (Exception e) {
  91.             e.printStackTrace();
  92.         }
  93.     }
  94. }
  95. ​

NetDiskUrl.java

  1. package com.bridge;
  2. ​
  3. public class NetDiskUrl {
  4. ​
  5.     private String title;
  6. ​
  7.     private String  subTitle;
  8. ​
  9.     private String url;
  10. ​
  11.     private String code;
  12. ​
  13.     @Override
  14.     public String toString() {
  15.         return "NetDiskUrl{" +
  16.                 "title='" + title + '\'' +
  17.                 ", subTitle='" + subTitle + '\'' +
  18.                 ", url='" + url + '\'' +
  19.                 ", code='" + code + '\'' +
  20.                 '}';
  21.     }
  22. ​
  23.     public String getTitle() {
  24.         return title;
  25.     }
  26. ​
  27.     public void setTitle(String title) {
  28.         this.title = title;
  29.     }
  30. ​
  31.     public String getSubTitle() {
  32.         return subTitle;
  33.     }
  34. ​
  35.     public void setSubTitle(String subTitle) {
  36.         this.subTitle = subTitle;
  37.     }
  38. ​
  39.     public String getUrl() {
  40.         return url;
  41.     }
  42. ​
  43.     public void setUrl(String url) {
  44.         this.url = url;
  45.     }
  46. ​
  47.     public String getCode() {
  48.         return code;
  49.     }
  50. ​
  51.     public void setCode(String code) {
  52.         this.code = code;
  53.     }
  54. }
​

JDBCUtils.java

  1. package com.bridge.jdbc;
  2. ​
  3. import com.bridge.NetDiskUrl;
  4. ​
  5. import java.io.InputStream;
  6. import java.sql.*;
  7. import java.util.List;
  8. import java.util.Properties;
  9. ​
  10. /**
  11.  * 封装数据库连接和关闭
  12.  */
  13. ​
  14. public class JDBCUtils {
  15.     public static Connection getConnection() throws Exception {
  16.         //读取配置文件基本信息
  17.         InputStream is = ClassLoader.getSystemClassLoader().getResourceAsStream("jdbc.properties");
  18.         Properties pros = new Properties();
  19.         pros.load(is);
  20.         String user = pros.getProperty("user");
  21.         String password = pros.getProperty("password");
  22.         String url = pros.getProperty("url");
  23.         String driverClass = pros.getProperty("driverClass");
  24.         //加载驱动
  25.         Class.forName(driverClass);
  26.         //获取连接
  27.         return DriverManager.getConnection(url, user, password);
  28.     }
  29. ​
  30.     public static void closeResource(Connection conn, Statement ps) {
  31.         try {
  32.             if (ps != null)
  33.                 ps.close();
  34.         } catch (SQLException e) {
  35.             e.printStackTrace();
  36.         }
  37.         try {
  38.             if (conn != null)
  39.                 conn.close();
  40.         } catch (SQLException e) {
  41.             e.printStackTrace();
  42.         }
  43.     }
  44. ​
  45.     public static void closeResource(Connection conn, Statement ps, ResultSet rs) {
  46.         try {
  47.             if (ps != null)
  48.                 ps.close();
  49.         } catch (SQLException e) {
  50.             e.printStackTrace();
  51.         }
  52.         try {
  53.             if (conn != null)
  54.                 conn.close();
  55.         } catch (SQLException e) {
  56.             e.printStackTrace();
  57.         }
  58.         try {
  59.             if (rs != null)
  60.                 rs.close();
  61.         } catch (SQLException e) {
  62.             e.printStackTrace();
  63.         }
  64.     }
  65. ​
  66.     public static void insert() throws Exception {
  67.         Connection conn = JDBCUtils.getConnection();
  68.         Statement st = conn.createStatement();
  69.         for (int i = 1; i <= 20000; i++) {
  70.             String sql = "insert into goods(name) values('name_" + i + "')";
  71.             st.execute(sql);
  72.         }
  73.     }
  74. ​
  75.     public static void testInsert1(){
  76.         Connection conn = null;
  77.         PreparedStatement ps = null;
  78.         try {
  79.             long start = System.currentTimeMillis();//计算花费时间
  80.             conn = JDBCUtils.getConnection();
  81.             String sql = "insert into goods(name) values(?)";
  82.             ps = conn.prepareStatement(sql);
  83.             for(int i = 1;i<=20000;i++){
  84.                 ps.setObject(1,"name_"+i);
  85.                 ps.execute();
  86.             }
  87.             long end = System.currentTimeMillis();
  88.             System.out.println(end-start+"s");
  89.         }catch (Exception e){
  90.             e.printStackTrace();
  91.         }finally {
  92.             JDBCUtils.closeResource(conn,ps);
  93.         }
  94.     }
  95. ​
  96. ​
  97.     /**
  98.      * 批量提交
  99.      */
  100.     public static void batchCommitInsert(List<NetDiskUrl> list) {
  101.         Connection conn = null;
  102.         PreparedStatement ps = null;
  103.         try {
  104.             long start = System.currentTimeMillis();//计算花费时间
  105.             conn = JDBCUtils.getConnection();
  106.             conn.setAutoCommit(false);//不允许自动提交数据
  107.             String sql = "INSERT INTO test.t_baidu_url (id,title, sub_title, url, code) VALUES(? , ?, ?, ?, ?);";
  108.             ps = conn.prepareStatement(sql);
  109.             for (int i= 0;i < list.size();i++) {
  110.                 NetDiskUrl diskUrl = list.get(i);
  111.                 ps.setObject(1, i);
  112.                 ps.setObject(2, diskUrl.getTitle());
  113.                 ps.setObject(3, diskUrl.getSubTitle());
  114.                 ps.setObject(4, diskUrl.getUrl());
  115.                 ps.setObject(5, diskUrl.getCode());
  116.                 //1、“攒”sql
  117.                 ps.addBatch();
  118.                 if (i % 500 == 0) {
  119.                     //2、执行batch
  120.                     ps.executeBatch();
  121.                     //3、清空batch
  122.                     ps.clearBatch();
  123.                 }
  124.             }
  125.             //提交数据
  126.             conn.commit();
  127.             long end = System.currentTimeMillis();
  128.             System.out.println(end - start + "ms");
  129.         } catch (Exception e) {
  130.             e.printStackTrace();
  131.         } finally {
  132.             JDBCUtils.closeResource(conn, ps);
  133.         }
  134.     }
  135. }
​

Python webdriver.Chrome()的使用

webdriver.Chrome()的使用

1.前提 Python与Chrome路径下均安装chromedriver.exe。

2.chromedriver.exe版本选择及下载 下载地址为：CNPM Binaries Mirror Chrome版本查看：浏览器右上角三个点->帮助->关于Google Chrome

在这里插入图片描述

chromedriver.exe版本需要与浏览器版本一致或者接近：

在这里插入图片描述

3.安装 下载后解压，将 chromedriver.exe复制到下面两个目录中：

Chrome目录：比如C:\Program Files (x86)\Google\Chrome\Application Python目录：比如D:\Softwares\Python39

4.添加环境变量 将上述Chrome路径添加进系统环境光变量，Python使用时应该加入环境变量了，这个就不用管了。

from selenium import webdriver
from selenium.webdriver.common.keys import Keys
from selenium.webdriver.common.by import By

Python实现自动分享

安装python3.8.X

Python Release Python 3.8.10 | Python.org

  1. from selenium import webdriver
  2. from selenium.webdriver.common.keys import Keys
  3. from selenium.webdriver.common.by import By
  4. import time
  5. import pymysql
  6. ​
  7. # 创建链接
  8. # 赋值给 conn连接对象
  9. # Python3.8。  我的修改方法：将 find_element_by_属性("value") 改为 find_element("By.属性","value")
  10. # 保存到百度云盘的方法
  11. def save_bdy(conn):
  12.     try:
  13.         # 获取数据库游标
  14.         cursor = conn.cursor()
  15.         # 查询保存了资源分享链接的res_url，和密码：captcha，状态为0表示没有处理
  16.         cursor.execute("select id rID, url, code from t_baidu_url where status = '0' ")
  17.         # 将保存好后的资源对应的记录状态标记为1
  18.         update_sql = "update t_baidu_url set status = '1' where id = %d "
  19.         results = cursor.fetchall()
  20.         # 创建Chrome浏览器，显示界面的，为了后面刚开始需要网盘登录时使用
  21.         browser = webdriver.Chrome()
  22.         #打开链接 30s内登录
  23.         browser.get("https://pan.baidu.com/")
  24.         time.sleep(30)
  25.         for (rID, url, code) in results:
  26.             try:
  27.                 # 打开资源分享链接
  28.                 browser.get(url)
  29.                 # 判断是否有密码
  30.                 if code:
  31.                     # 获取资源密码输入框
  32.                     pwd = browser.find_element(By.ID, 'accessCode')
  33.                     # 在框中输入密码
  34.                     pwd.send_keys(code)
  35.                     # 延时4秒
  36.                     time.sleep(4)
  37.                     # 发送回车键进入到资源页面
  38.                     pwd.send_keys(Keys.ENTER)
  39.                 time.sleep(10)
  40.                 # 找到“保存到网盘”的这个按钮
  41.                 button = browser.find_element(By.CSS_SELECTOR, 'a[title="保存到网盘"]')
  42.                 # 单击，注意这时候断点到这里停一下，如果如要认证，你可以填写认证可扫码认证都可以，
  43.                 # 认证好后，会出现选择文件夹这个对话框，
  44.                 # 只需要认证一次，后续出直接弹出这个文件选择框，自动进行即可
  45.                 # 注意一定到断点，进你进行认证时后续程序不要执行
  46.                 button.click()
  47.                 time.sleep(5)
  48.                 # 在文件夹选择对话框中选择你想到保存到的文件夹，比如我的资源
  49.                 fold = browser.find_element(By.CSS_SELECTOR, 'span[node-path="/编程书籍大全"]')
  50.                 # 单击这个文件夹就会选中
  51.                 fold.click()
  52.                 time.sleep(1)
  53.                 # 然后获取确定按钮并单击就保存成功了
  54.                 ok = browser.find_element(By.CSS_SELECTOR, 'a[title="确定"]')
  55.                 ok.click()
  56.                 time.sleep(5)
  57.                 cur = conn.cursor()
  58.                 try:
  59.                     # 保存成功后，就修改数据库记录的状态
  60.                     cur.execute(update_sql % rID)
  61.                     conn.commit()
  62.                 except Exception as e:
  63.                     conn.roleback()
  64.                     print(e)
  65.                 finally:
  66.                     cur.close()
  67.             # 异常忽略
  68.             except Exception as e:
  69.                 print(e)
  70.     except Exception as e:
  71.         print(e)
  72. ​
  73. if __name__ == '__main__':
  74.     conn = pymysql.connect(
  75.         host='127.0.0.1',  # 本地回环地址
  76.         port=3306,  # 默认端口
  77.         user='xxx',  # 用户名  如：root
  78.         密码英文='xxx',  # 密码 如：root
  79.         database='test',  # 连接数据库名称
  80.         charset='utf8'  # 编码 不能写utf-8
  81.     )
  82.     save_bdy(conn)

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/酷酷是懒虫/article/detail/807782
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号