基于Java+MySQL实现移动新闻客户端

移动新闻客户端的设计与实现一、实验名称移动新闻客户端的设计与实现二、实验目的结合具体应用全面掌握移动应用开发技术、后台 Web 管理系统开发技术、数据库设计技术和 Web 接口调用技术等。三、实验内容1 在实验 2 的研究基础上实现对多新闻网站、多栏目的动态定时增量采集功能具体采集源、采集规则和采集结果可通过 Web 后台进行浏览和查看2 实现采集的新闻信息在移动端的展示和浏览功能。移动端的实现方式可以选择 Html5 网页形式、微信小程序形式、混合开发模式如 APICloud或者原生开发模式任选其一即可。四、实验要求1 基于 Java 语言及相关技术框架实现2 移动端功能包括类似今日头条的新闻列表显示功能支持下拉更新可选分类筛选可选等扩展功能3 Web 后端功能包括新闻动态采集功能实验 3 结果改进新闻增删改查功能可选新闻点击次数统计功能可选4接口实现方式HTTP 接口形式或 RESTFul 接口形式自选5实验采用分组实施方式每组 4 人。建议分工1 人担任组长负责组织大家共同完成总体设计包括总体架构、数据库设计及接口设计等1 人负责采集模块1 人负责管理后台1 人负责移动应用开发。要求既有分工又有协作。每个人的完成情况都直接与团队成绩关联。五、实验结果5.1 团队构成及分工团队成员及分工信息如表 1 所示。表 1 团队构成及分工序号学号班级姓名任务分工1183401050225软件 1802任组长一职负责总体设计、小程序云开发以及部分前端交互逻辑、后端的部分代码2183401050219软件 1802负责移动应用开发主要是微信小程序的前端部分3183401050217软件 1802负责移动应用开发主要是微信小程序的前端部分4183401050226软件 1802负责后端新闻采集模块5.2 总体设计方案(1) 总体架构我们采用了 C/SB/S 内外有别模式示意图如图 1 所示。内部用户通过后端直接访问数据库服务器对新闻信息进行管理响应速度更高。外部用户通过互联网访问 Web 服务器这里是指部署在微信服务器上的云函数数据更安全。系统的处理流程如图 2 所示。图 1 架构示意图图 2 处理流程(2) 数据库设计首先建立两个基本表 news_info 和 news_extrainfo。其中news_info 表用于存储新闻的基本信息如新闻类别、新闻标题、采集时间等news_extrainfo 表用于存储新闻的扩展信息包括新闻来源、发布时间等。两个基本表通过 id 这一字段可以进行连接。两个基本表所对应的关系模式的最高规范化程度都达到了 BCNF。表 news_info 和 news_extrainfo 的结构如表 2、3 所示。表 2 表 news_info 的结构信息FieldTypeNullKeyDefaultExtraidint unsignedNOPRINULLauto_incrementtitlevarchar(100)NOUNINULLcategoryvarchar(40)NONULLcollect_timedatetimeNONULL表 3 表 news_extrainfo 的结构信息FieldTypeNullKeyDefaultExtraidint unsignedNOPRINULLsourcevarchar(40)YESNULLrelease_timedatetimeYESNULL根据基本表 news_info 和 news_extrainfo 建立视图 news_fullinfo。该视图包含了新闻列表页面上需要展出的全部信息。视图 news_fullinfo 的结构如表 4 所示。表 4 视图 news_fullinfo 的结构信息FieldTypeNullKeyDefaultExtratitlevarchar(100)YESNULLcategoryvarchar(40)YESNULLsourcevarchar(40)YESNULLformatted_release_timevarchar(24)YESNULL5.3 部分概述本人负责总体设计、小程序部分代码的编写以及后端部分代码的编写工作具体内容见表 5。表 5 部分总览序号内容对应成果1总体设计总体设计方案见 5.2 小节2小程序云开发cloudfunctions\mysql_select\index.js3小程序部分前端交互逻辑miniprogram\pages\mysql\select\select.js4小程序总体框架与样式miniprogram\app.jsonminiprogram\app.wxss5后端的部分代码src/DatabaseHelper.javasrc/Main.javasrc/MyTimerTask.java5.4 部分成果cloudfunctions\mysql_select\index.js// 云函数入口文件 const cloud require(wx-server-sdk) //引入mysql操作模块 const mysql require(mysql2/promise) cloud.init() // 云函数入口函数 exports.main async (event, context) { try { const connection await mysql.createConnection({ host: sh-cynosdbmysql-grp-cmcvr92o.sql.tencentcdb.com, // 云数据库连接外网地址 port: 23444, user: root, password: Password123456, database: BaiduNews, charset: utf8mb4 }) const [rows] await connection.execute( SELECT title, source, formatted_release_time FROM news_fullinfo WHERE category? ORDER BY formatted_release_time DESC;, [event.category]) return rows; } catch (err) { console.log(链接错误, err) return err } } miniprogram\pages\mysql\select\select.js // miniprogram/pages/mysql/select/select.js Page({ / * 向列表中添加新的新闻 */ appendList: function (data) { this.setData({ listData: this.data.listData.concat(data) }) }, / * 从云端 MySQL 获取新闻 */ getNews: function (category) { let scope this wx.cloud.callFunction({ name: mysql_select, data: { // 传参 category: category } }).then(res { console.log(getNews -- 从云端 MySQL 获取新闻) console.log(res) var keys Object.keys(res.result); console.log(获取到的新闻条数 keys.length) for (var i 0; i ((100 keys.length) ? 100 : keys.length)/keys.length/; i) { scope.appendList({ title: res.resultkeys[i], formatted_release_time: res.resultkeys[i], source: res.resultkeys[i] }) } console.log(展示出的新闻条数 min { 100 , 获取到的新闻条数 } this.data.listData.length) }) }, / * 页面的初始数据 */ data: { category: , listData: [], hasPullDownRefresh: false }, / * 生命周期函数--监听页面加载 */ onLoad: function (options) { this.setData({ category: options.category }) console.log(onLoad -- category is: this.data.category) var titleStr (this.data.category 首页) ? 热点要闻 : this.data.category wx.setNavigationBarTitle({ title: titleStr, }) this.getNews(this.data.category) }, / * 生命周期函数--监听页面初次渲染完成 */ onReady: function () { }, / * 生命周期函数--监听页面显示 */ onShow: function () { }, / * 生命周期函数--监听页面隐藏 */ onHide: function () { }, / * 生命周期函数--监听页面卸载 */ onUnload: function () { }, / * 页面相关事件处理函数--监听用户下拉动作 */ onPullDownRefresh: function () { if (this.data.hasPullDownRefresh) { return } this.setData({ hasPullDownRefresh: true }) wx.showLoading({ // 显示 loading 提示框 title: 加载中, }) console.log(onPullDownRefresh -- category is: this.data.category) this.data.listData.length 0 this.setData({ listData: this.data.listData // 清空 listData }) this.getNews(this.data.category) wx.hideLoading() // 关闭提示框 wx.stopPullDownRefresh() // 停止当前页面下拉刷新 this.setData({ hasPullDownRefresh: false }) }, / * 页面上拉触底事件的处理函数 */ onReachBottom: function () { }, / * 用户点击右上角分享 */ onShareAppMessage: function () { } }) miniprogram\app.json { pages: [ pages/index/index, pages/mysql/select/select ], window: { backgroundColor: #F6F6F6, backgroundTextStyle: dark, navigationBarBackgroundColor: #F6F6F6, navigationBarTitleText: 移动新闻客户端, navigationBarTextStyle: black, enablePullDownRefresh: true }, sitemapLocation: sitemap.json, style: v2 } miniprogram\app.wxss /app.wxss/ .container { display: flex; flex-direction: column; align-items: center; box-sizing: border-box; } page { background: #f6f6f6; display: flex; flex-direction: column; justify-content: flex-start; } .item { margin-top: 40rpx; height: 140rpx; width: 100%; background: #fff; border: 1px solid rgba(0, 0, 0, 0.1); border-left: none; border-right: none; display: flex; flex-direction: row; align-items: center; transition: all 300ms ease; } .item { height: auto; padding-left: 40rpx; padding-right: 40rpx; flex-direction: column; align-items: flex-start; box-sizing: border-box; } .item-text { width: 100%; line-height: 52px; font-size: 34rpx; } src/DatabaseHelper.java // DatabaseHelper.java import java.sql.*; import java.util.ArrayList; / * 数据库访问与操作类 */ public class DatabaseHelper { // 数据库 URL云数据库连接外网地址用户名与密码 static final String DB_URL jdbc:mysql://sh-cynosdbmysql-grp-cmcvr92o.sql.tencentcdb.com:23444/BaiduNews?useSSLfalseallowPublicKeyRetrievaltrueserverTimezoneAsia/Shanghai; static final String USERNAME root; static final String PASSWORD Password123456; / * 建立一个到数据库的连接 * * return 与数据库连接的 {code Connection} 对象 */ public static Connection getConnection() throws SQLException { return DriverManager.getConnection(DB_URL, USERNAME, PASSWORD); } / * 把新闻插入数据库中 * * param newsList 从 {link NewsInfoGetter#getNews()} 获得的新闻信息 */ public static void insertNewsInfo(ArrayListNewsInfoGetter.News newsList) throws Exception { try (Connection connection getConnection()) { PreparedStatement preStatement connection.prepareStatement( INSERT IGNORE INTO news_info ( title, category, collect_time ) VALUES ( ?, ?, ? ), Statement.RETURN_GENERATED_KEYS ); PreparedStatement preStatement2 connection.prepareStatement( INSERT INTO news_extrainfo ( id, source, release_time ) VALUES ( ?, ?, ? ) ); int updatedNewsCount 0, ignoredNewsCount 0; for (NewsInfoGetter.News news : newsList) { preStatement.setString(1, news.getTitle()); preStatement.setString(2, news.getCategory()); preStatement.setTimestamp(3, news.getCollect_time()); int r preStatement.executeUpdate(); if (r ! 0) { System.out.println([已更新 1 条] 类别 news.getCategory() 标题 news.getTitle()); NewsExtraInfoGetter.NewsExtraInfo newsExtraInfo NewsExtraInfoGetter.getNewsExtraInfo(news); ResultSet rs preStatement.getGeneratedKeys(); if (newsExtraInfo ! null rs.next()) { preStatement2.setInt(1, rs.getInt(1)); preStatement2.setString(2, newsExtraInfo.getSource()); preStatement2.setTimestamp(3, newsExtraInfo.getRelease_time()); preStatement2.executeUpdate(); } updatedNewsCount; } else { System.out.println([已存在未更新] 类别 news.getCategory() 标题 news.getTitle()); ignoredNewsCount; } } System.out.println(已更新 updatedNewsCount 条新闻 ignoredNewsCount 条重复新闻未更新); } catch (SQLException throwables) { throwables.printStackTrace(); } } } src/Main.java // Main.java / * Main 类 */ public class Main { public static void main(String[] args) { try { DatabaseHelper.insertNewsInfo(NewsInfoGetter.getNews()); } catch (Exception e) { e.printStackTrace(); } } } src/MyTimerTask.java // MyTimerTask.java import java.text.SimpleDateFormat; import java.util.Date; import java.util.Timer; import java.util.TimerTask; / * 让程序定时爬取新闻 */ public class MyTimerTask extends TimerTask { private Timer timer new Timer(); public static void main(String[] args) { MyTimerTask t new MyTimerTask(); t.start(); } Override public void run() { System.out.println(程序运行中...); Main.main(new String[]{}); // 获取新闻 printTime(); } public void start() { // 半个小时执行一次 timer.scheduleAtFixedRate(this, new Date(), 1000 * 30 * 60); } public void printTime() { Date date new Date(); System.out.println(定时执行程序 new SimpleDateFormat(yyyy-MM-dd HH:mm:ss).format(date.getTime())); } }六、测试结果新闻分类筛选界面如图 3 所示。图 3 新闻分类筛选界面新闻列表显示界面如图 4 所示。图 4 新闻列表显示界面下拉更新功能如图 5 所示。图 5 下拉更新功能新闻定时增量采集功能如图 6 所示。图 6 新闻定时增量采集功能♻️ 资源大小8.67MB➡️资源下载https://download.csdn.net/download/s1t16/87415910注更多内容可关注微信公众号【神仙别闹】如当前文章或代码侵犯了您的权益请私信作者删除