zoukankan      html  css  js  c++  java
  • php与Redis实现一个100万用户的投票项目,如何实现实时查看投票情况?

    好了,什么是冷热数据交换呢?

    很土的解释一下,冷数据就是之前使用的数据,有种过去式的感觉,而热数据就是当前的数据,理解为现在进行时吧。如何交换呢?就是将Redis的数据周期存储到mysql中!

     整体的业务流程

    用户投票后,首先将投票数据保存到Redis。 这些数据是热数据,然后写个定时任务,定时(例如10s)将热数据保存到MySQL。 这些数据成为冷数据,然后从Redis删除冷数据。 一遍又一遍,直到一个小时的投票结束了。

     数据表构建

     结构文件我们这里分index.html ,  vote.php , swap.php  分别来处理

    index.html

    这是投票的页面,假如有3个投票按钮,我们模拟给3个用户投票,点击按钮,使用ajax调用vote.php文件

    vote.php文件

    <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd">
    <html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en">
    <head>
        <meta http-equiv="Content-Type" content="text/html;charset=UTF-8">
        <title>Document</title>
    </head>
    <script src="http://lib.sinaapp.com/js/jquery/1.9.1/jquery-1.9.1.min.js"></script>
    <body>
    <p><span id="uid1">0</span><input type="button" value="用户1" onclick="vote(1);" /></p>
    <p><span id="uid2">0</span><input type="button" value="用户2" onclick="vote(2);" /></p>
    <p><span id="uid3">0</span><input type="button" value="用户3" onclick="vote(3);" /></p>
    </body>
    <script>
        function vote(i){
            $.get('./vote.php?uid='+i,function(rs){
                var span = '#uid'+i;
                $(span).html(rs);
            });
        }
    </script>
    </html>

    vote.php

    这个文件是实现投票的逻辑。首先连接上Redis服务器,然后保存投票人id,然后将投票人id为key记录每个用户的票数,然后返回给index.html文件,最后使用global_voteid作为key记录总票数,也可以作为MySQL的自增长的键。然后记录uid,ip,time等数据。

    swap.php 文件

    主要目的是交换热数据和冷数据。 首先,连接MySQL数据库和Redis服务器,然后每10秒执行一次while循环。 在while循环中,获取插入到mysql中的自增长投票主键和最新投票主键(位置)。确定插入位置是否存在。 如果不存在,请从头开始插入。 如果所有插入均已完成,请等待。 如果未插入,请执行插入操作

     运行步骤如下:

    1、运行 swap.php 文件,redis监听投票

    linux系统使用php命令行工具调用swap.php (推荐使用这种方法)

     

     2.模拟请求投票

     

     

    有需要学习交流的友人请加入交流群的咱们一起,群内都是1-7年的开发者,希望可以一起交流,探讨PHP,swoole这块的技术 或者有其他问题 也可以问,获取swoole或者php进阶相关资料私聊管理即可

    点此加入该群​jq.qq.com

    推荐阅读:

    phper使用MySQL 针对千万级的大表要怎么优化?

    PHP高并发和大流量的解决方案

  • 相关阅读:
    抽象类与接口 【转载】
    linux网卡驱动程序架构
    linux回环网卡驱动设计
    命令行启动appium服务
    Java+Maven的工程运行Sonar的方式
    使用Fabric在tomcat中部署应用的问题总结
    Fabric的使用总结
    利用xcode Build生成模拟器运行包
    Jenkins配置git/github 插件的ssh key
    Jenkins插件--通知Notification
  • 原文地址:https://www.cnblogs.com/heyue0117/p/12073265.html
Copyright © 2011-2022 走看看