首页 > 编程 > JavaScript > 正文

使用node搭建自动发图文微博机器人的方法

2019-11-19 11:57:25
字体:
来源:转载
供稿:网友

本文仅供学习交流,请勿用于商业用途,并遵守新浪微博相关规定。

代码目录

此微博机器人的实现功能如下:

  • 模拟登陆新浪微博,获取cookie;
  • 自动上传图片至微博图床;
  • 自动发送内容不同的图文微博;
  • 通过定时任务,实现周期性发微博任务。

效果图


图文内容我固定了,可自行使用第三方api获取要发送的内容或爬取第三方内容发送。(偷个懒...

要实现发送图文微博可以分为三个步骤

  • 登录微博。
  • 图片上传至微博图床获取PID。
  • 发送微博。

登录

登录可以使用Puppeteer node库,很轻松的实现登录获取微博cookie,这里不多介绍,可以自行搜索Puppeteer学习。

Puppeteer是谷歌官方出品的一个通过DevTools协议控制headless Chrome的Node库。可以通过Puppeteer的提供的api直接控制Chrome模拟大部分用户操作来进行UI Test或者作为爬虫访问页面来收集数据。
async function login(username, password) {  const browser = await puppeteer.launch({    // headless: false,    slowMo: 250,    executablePath: ''  });  const page = (await browser.pages())[0];  await page.setViewport({    width: 1280,    height: 800  });  await page.goto("https://weibo.com/");  await page.waitForNavigation();  await page.type("#loginname", username);  await page.type("#pl_login_form > div > div:nth-child(3) > div.info_list.password > div > input", password);  await page.click("#pl_login_form > div > div:nth-child(3) > div:nth-child(6)");  await page.waitForNavigation().then(result => {    return new Promise((resolve) => {      page.cookies().then(async cookie => {        fs.createWriteStream("cookie.txt").write(JSON.stringify(cookie), "UTF8");//存储cookie        await browser.close();//关闭打开的浏览器        resolve(cookie);      });    })  }).catch(e => {    page.screenshot({      path: 'code.png',      type: 'png',      x: 800,      y: 200,      width: 100,      height: 100    });    return new Promise((resolve, reject) => {      readSyncByRl("请输入验证码").then(async (code) => {        await page.type("#pl_login_form > div > div:nth-child(3) > div.info_list.verify.clearfix > div > input", code);        await page.click("#pl_login_form > div > div:nth-child(3) > div:nth-child(6)");        await page.waitForNavigation();        page.cookies().then(async cookie => {          fs.createWriteStream("cookie.txt").write(JSON.stringify(cookie), "UTF8");          await browser.close();          resolve(cookie);        });      })    })  })}

图片上传至微博图床

上传到微博图床可以看这里 http://weibo.com/minipublish 抓包看上传的接口过程,可以看到上传的是base64图片信息。所以上传前把图片转换成base64编码,而本地图片的编码和互联网链接图片的编码又不一样,这里使用的是互联网链接的图片,node本地图片转换成base64编码更简单些。上传成功后返回微博图床图片的pid。记住这个pid,发微博用的就是这个pid。

发送微博

有了微博cookie和图片pid后就可以发微博了,多张图片时pid之间以|隔开的。

async function weibopost(text, pic_ids = '', cookie) { //发送微博内容(支持带图片)  return new Promise(async (resolve, reject) => {    if (cookie === '') {      reject('Error: Cookie not set!');    }    let post_data = querystring.stringify({      'location': 'v6_content_home',      'text': text,      'appkey': '',      'style_type': '1',      'pic_id': pic_ids,      'tid': '',      'pdetail': '',      'mid': '',      'isReEdit': 'false',      'rank': '0',      'rankid': '',      'module': 'stissue',      'pub_source': 'main_',      'pub_type': 'dialog',      'isPri': '0',      '_t': '0'    });    let post_options = {      'Accept': '*/*',      'Accept-Encoding': 'gzip, deflate, br',      'Accept-Language': 'zh-CN,zh;q=0.9,en;q=0.8,zh-TW;q=0.7',      'Connection': 'keep-alive',      'Content-Length': Buffer.byteLength(post_data),      'Content-Type': 'application/x-www-form-urlencoded',      'Cookie': cookie,      'Host': 'weibo.com',      'Origin': 'https://weibo.com',      'Referer': 'https://weibo.com',      'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_13_3) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/64.0.3282.167 Safari/537.36',      'X-Requested-With': 'XMLHttpRequest'    };    let {      data    } = await axios.post('https://weibo.com/aj/mblog/add?ajwvr=6&__rnd=' + new Date().getTime(), post_data, {      withCredentials: true,      headers: post_options    })    if (data.code == 100000) {      console.log('/n' + text + '-----Sent!' + '---' + new Date().toLocaleString());      resolve(data);    } else {      console.log('post error');      reject('post error');    }  });}

最后就是定时任务了,定时任务可以使用node-schedule node库,这里不多介绍,可以自行搜索学习。这里使用的是每隔10分钟发送一次。

function loginTo() {  login(config.username, config.password).then(async () => {    let rule = null;    rule = new schedule.RecurrenceRule();    rule.minute = [01, 11, 21, 31, 41, 51];    try {      let cookie = await getCookie();      getContent(cookie);    } catch (error) {      console.log(error);    }    j = schedule.scheduleJob(rule, async () => { //定时任务      try {        let cookie = await getCookie();        getContent(cookie);      } catch (error) {        console.log(error);      }    });  })}

代码地址: github地址

参考

https://github.com/itibbers/weibo-post

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持武林网。

发表评论 共有条评论
用户名: 密码:
验证码: 匿名发表