之前用request爬取猫眼电影时，

由于猫眼把电影信息变成了动态获取，因此无法直接用源代码爬取。

现在通过selenium直接点进电影信息时发现，

即使首页面加了防检测，但只能在当前页面生效，打开的新页面window.navigator.wevdrive===True，依旧无法获取电影信息，因此仍无法用selenium获取多条电影信息。

因此通过request爬取电影目录，selenium爬取电影信息，总算是成功爬取了电影信息，目前猫眼评分转了码问题仍未解决

from selenium import webdriver
from selenium.webdriver.chrome.service import Service
from selenium.webdriver.common.by import By
from time import sleep
import requests
from fake_useragent import UserAgent
from lxml import etree
from queue import Queue
from threading import Thread


def get_film_list(page):
    film_list = []
    for i in range(page):
        url = f'https://www.maoyan.com/films/?showType=3&offset={30*i}'
        headers = {'User-Agent': UserAgent().chrome}
        resp = requests.get(url, headers = headers)
        html = etree.HTML(resp.text)
        films = html.xpath('//dd/div[@title]/a/@href')
        for film in films:
            film_list.append(film)
        sleep(1)
    return film_list


def get_film_data(film):
    url = f'https://www.maoyan.com{film}'
    options = webdriver.ChromeOptions()
    # 设置无头
    options.add_argument('--headless')
    # 防检测1
    options.add_experimental_option('excludeSwitches', ['enable-automation'])
    options.add_experimental_option('useAutomationExtension', False)

    service = Service(executable_path='./tools/chromedriver')
    chrome = webdriver.Chrome(service=service, options=options)
    chrome.implicitly_wait(2)

    # 防检测2
    chrome.execute_cdp_cmd("Page.addScriptToEvaluateOnNewDocument", {
        "source": """
            Object.defineProperty(navigator, 'webdriver', {
              get: () => false
            })
          """
    })

    chrome.get(url)
    name = chrome.find_element(By.XPATH, '//h1[@class="name"]').text
    type_ = [i.text for i in chrome.find_elements(By.XPATH, '//a[@class="text-link"]')]
    chrome.find_element(By.XPATH, '//div[@class="tab-title "]').click()
    actors = []
    for i in chrome.find_elements(By.XPATH, '//li[@class="celebrity actor"]/div/a'):
        if i.text and i.text not in actors:
            actors.append(i.text.strip())

    info = {'电影名': name, '类型': type_, '主演': actors}
    return info


def create_quere(list):
    q = Queue()
    for i in list:
        q.put(i)
    return q


class MyThread(Thread):
    def __init__(self, q):
        Thread.__init__(self)
        self.__q = q

    def run(self) -> None:
        while not self.__q.empty():
            film = self.__q.get()
            film_info = get_film_data(film)
            print(film_info)


if __name__ == '__main__':
    film_list = get_film_list(1)
    q = create_quere(film_list)
    for i in range(3):
        t = MyThread(q)
        t.start()

老师，这里爬到一些数据像是转码过了，有什么办法解码吗

我在学校学习了java，然后下载的jdk是8和17的

mysql报错了？

老师 这个流对象为什么不需要关闭

老师你好：

老师我有点不理解图一的账户余额是怎么来的，是图二红框这个方法随机生成的嘛？

谢谢老师

老师为什么数据库中tinyint类型的数据在使用逆向工程生成POJO之后就变成boolean类型了，我查了一下tinyint类型只是占1个字节的int类型的，没有什么特殊的，为什么就变成boolean类型了

老师，我理解下；

a = MySingleton("aa")   先调用类MySingleton中；

然后因为类属性__obj初始值是None，所以会调用object类的__new__方法创建一个实例；赋值给__obj并输出；

然后进行到初始化方法__init__，因为类属性__init_flag初始值是True，所以必定会执行，初始化name=aa；将值False赋予类属性__init_flag；

因为__init_flag为False，后续调用此类，不会再操作初始化方法；

这样理解有没有问题？

老师，特征值与奇异值的关系中，特征值是指U的特征值，还是指V的特征值呢？因为U、V都有对应的特征值

请问老师，这里是如何看出的？

这里为啥只引用了Home和AD的路由，About的呢？

为什么图片显示不出来呢

如何看待35岁危机？

import sun.dc.pr.PRError;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;

/**
 * 发送消息
 */
class Send1 extends Thread{
    private Scanner scanner;
    private Socket socket;
    public Send1(Socket socket,Scanner scanner){
        this.socket=socket;
        this.scanner=scanner;
    }

    @Override
    public void run() {
        this.Send1Msg();
    }
    public void Send1Msg(){
        try (PrintWriter pw=new PrintWriter(socket.getOutputStream());){
            while (true){
                String msg=scanner.nextLine();
                pw.println(msg);
                pw.flush();
            }
        }catch (Exception e){
            e.printStackTrace();
        }
    }
}

/**
 * 接收消息的线程
 */
class Receive1 extends Thread{
    private Socket socket;
    public  Receive1(Socket socket){
        this.socket=socket;
    }

    @Override
    public void run() {
        this.ReceiveMsg();
    }
    public void ReceiveMsg(){
        try (BufferedReader br=new BufferedReader(new InputStreamReader(socket.getInputStream()));){
            String msg=br.readLine();
            System.out.println("他说:"+msg);

        }catch (Exception e){
            e.printStackTrace();
        }
    }
}
public class GoodTCP {
    public static void main(String[] args) {
        ServerSocket serverSocket=null;
        Socket socket=null;
        try {
            Scanner scanner=new Scanner(System.in);
            System.out.println("请输入：server,<port> 或者：<ip>,<port>");
            String str=scanner.nextLine();
            String[] arr=str.split(",");
            //启动服务器
            if ("server".equals(arr[0])){
                System.out.println("TCP Server Listen at "+arr[1]+".......");
                serverSocket=new ServerSocket(Integer.parseInt(arr[1]));
                socket=serverSocket.accept();
            }else {//启动客户端
                socket=new Socket(arr[0],Integer.parseInt(arr[1]));
                System.out.println("连接成功");
            }
            //启动发送消息的线程
            new Send1(socket,scanner).start();
            //启动接收消息的线程
            new Receive1(socket).start();
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            if (serverSocket !=null){
                try {
                    serverSocket.close();
                }catch (IOException e){
                    e.printStackTrace();
                }
            }
        }
    }
}

为什么我的只能一次，而且另外一个也会运行回答null呢。