php 消息推送(含源码)

概述

今天刚好周六,昨天有人在群里问如何实习php的即时通讯。我也搜了搜资料,打算自己实现一遍php消息推送中的-ajax长轮询的。我觉得对php即时通讯的介绍写得比较好的是:

http://www.cnblogs.com/hnrainll/archive/2013/05/07/3064874.html

可以参考一下,其他我就不多说了,参考链接,优于用于演示,就没有操作数据库中的东西了。

我的代码

入口代码 index.html

<!DOCTYPE HTML>
<html>
<head>
    <title>反ajax推送</title>
    <style>
        .send{color:#555;text-align: left;}
        .require{color:blue;text-align: right;}
        .content_box{text-align: center;margin: 20px;
                    border: 1px solid #ddd;padding: 20px;}
    </style>
    <script src="http://code.jquery.com/jquery-1.11.2.min.js"></script>
</head>
<body>
    <div class="content_box" id="content_box_title" style="border: none;">消息框</div>
    <div class="content_box" id="content_box">
    </div>
    <div style="width: 450px;margin: 0 auto;">
        <select id="username" style="font-size: 20px;">
            <option value="1" selected="selected">1</option>
            <option value="2">2</option>
        </select>
        <input type="text" style="font-size: 20px;" value="" id="send_text">
        <button id="btn_send" style="font-size: 20px;">发送</button>
        <button id="btn_link" style="font-size: 20px">连接</button>
    </div>
    <div class="error_tip" id="error_tip" style="color: red;">
    </div>
    <script>
        $(function(){
            //发送消息
            $(‘#btn_send‘).click(function(){
                var send_text = $(‘#send_text‘).val();
                if(send_text.length <= 0){
                    $(‘#error_tip‘).html(‘不能输入空值‘);
                }else{
                    send(send_text);
                }
            });
            //按回车键发送消息
            $(‘#send_text‘).on(‘keyup‘,function(e){
                if(e.keyCode == 13){
                    $(‘#btn_send‘).trigger(‘click‘);
                }
            });
            //建立通讯链接
            $(‘#btn_link‘).click(function(){
                connect();
                var _this = $(this);
                _this.attr(‘disabled‘,true);
                _this.html(‘已连接‘);
            });

        });
        //建立通讯连接函数
        function connect(){
            $(‘#content_box_title‘).html($(‘#username‘).val()+‘的消息窗口‘);
            $.ajax({
                data:{‘user‘:$(‘#username‘).val()},
                url:‘ajaxPush.php‘,
                type:‘get‘,
                timeout:0,
                dataType:‘json‘,
                success:function(data){
                    $(‘#content_box‘).append(‘<div class="require">‘+data.msg+‘</div>‘);
                    connect();
                }
            });
        }
        //发送消息函数
        function send(massege){
            var user =$(‘#username‘).val();
            $.getJSON(‘write.php‘,{‘msg‘:massege,‘user‘:user},function(data){
                if(data.sf){
                    $(‘#content_box‘).append(‘<div class="send">‘+massege+‘</div>‘);
                    $(‘#send_text‘).val(‘‘);
                }else{
                    $(‘#error_tip‘).html(‘输入保存错误!‘);
                }
            });
        }
    </script>
</body>
</html>

ajax处理输入 write.php

<?php
/**
 * Created by TXM.
 * Time: 2015/4/18 13:13
 * function:
 */

$filename  = dirname(__FILE__).‘/data.txt‘;
$isread_file = dirname(__FILE__).‘/isread.txt‘;
$user = dirname(__FILE__).‘/user.txt‘;

//写入消息,消息未读,谁发送的消息
file_put_contents($filename,$_GET[‘msg‘]);
file_put_contents($isread_file,‘0‘);
file_put_contents($user,$_GET[‘user‘]);

echo json_encode(array(‘sf‘=>true));

长轮询推送 ajaxPush.php

<?php
/**
 * Created by TXM.
 * Time: 2015/4/18 13:12
 * function:
 */
$filename  = dirname(__FILE__).‘/data.txt‘;
$isread_file = dirname(__FILE__).‘/isread.txt‘;
$userfile = dirname(__FILE__).‘/user.txt‘;
$get_user = $_GET[‘user‘] == ‘1‘?‘2‘:‘1‘;
$msg=‘‘;

while(1){
    $msg = file_get_contents($filename);
    $isread = file_get_contents($isread_file);
    $user = file_get_contents($userfile);

    //是对方发送的消息,设置消息已读,退出循环。
    if($isread == ‘0‘ && $get_user == $user){
        file_put_contents($isread_file,‘1‘);
        break;
    }
    sleep(1);
}

echo json_encode(array(‘msg‘=>$msg));

效果

源码下载地址

http://pan.baidu.com/s/1pJ5elpp

时间: 2024-11-18 21:01:03

php 消息推送(含源码)的相关文章

消息推送之GCM

利用GCM进行消息推送 原理 1.接收端向GCM注册registerid 2.发送端发消息给GCM服务器 这个过程需要三个参数: (1)API Key (2)registerid (3)传递的数据 3.GCM端将消息转发给注册的设备(通过注册的registerid) 准备工作 1.projectid 这个是项目id,通过Google API控制台页面可以申请到.具体步骤不详细说了,网上好多. 申请网址:https://code.google.com/apis/console/ 2.API Key

基于SignalR的消息推送与二维码描登录实现

1 概要说明 使用微信扫描登录相信大家都不会陌生吧,二维码与手机结合产生了不同应用场景,基于二维码的应用更是比较广泛.为了满足ios.android客户端与web短信平台的结合,特开发了基于SinglarR消息推送机制的扫描登录.本系统涉及到以下知识点:     SignalR:http://signalr.net/ 这官网,ASP.NET SignalR 是为 ASP.NET 开发人员提供的一个库,可以简化开发人员将实时 Web 功能添加到应用程序的过程.实时 Web 功能是指这样一种功能:当

MPush开源消息推送系统:简洁、安全、支持集群

引言 由于之前自己团队需要一个消息推送系统来替换JPUSH,一直找了很久基本没有真正可用的开源系统 所有就直接造了个轮子,造轮子的时候就奔着开源做打算的,只是后来创业项目失败一直没时间整理 这一套代码,最近比较闲就拿出来给开源做点贡献. 作为Java版的开源推送系统,MPUSH还是有很多不错的设计的,特别是对想自己搭建一套推送系统的团队 是有很大的借鉴意义的.当然开源出来也是不想曾经做过的工作白白浪费掉,特别希望对这方面有兴趣的同学 来一起把这套东西做的更好,服务更多的用户! 项目主页 http

Android消息推送机制

1.推送方式基础知识: 当我们开发需要和服务器交互的应用程序时,基本上都需要获取服务器端的数据,比如<地震应急通>就需要及时获取服务器上最新的地震信息.要获取服务器 上不定时更新的信息一般来说有两种方法,第一种是客户端使用Pull(拉)的方式,隔一段时间就去服务器上获取信息,看是否有更新的信息出现.第二种就是 服务器使用Push(推送)的方式,当服务器端有新信息了,则把最新的信息Push到客户端上.? 虽然Pull和Push两种方式都能实现获取服务器端更新信息的功能,但是明显来说Push is

开源实时消息推送系统 MPush

系统介绍 mpush,是一款开源的实时消息推送系统,采用java语言开发,服务端采用模块化设计,具有协议简洁,传输安全,接口流畅,实时高效,扩展性强,可配置化,部署方便,监控完善等特点.同时也是少有的可商用的开源push推送系统. 特性和优势 源码全部开放,包括server.android.ios .websocket等 代码质量高,全部模块化设计,真正的商用级产品,考虑到推送中遇到的大部分场景 安全性高,基于RSA精简的加密握手协议,简单,高效,安全 支持断线重连,及弱网下的快速重连,无网络下

基于ajax与msmq技术的消息推送功能实现

周末在家捣鼓了一下消息推送的简单例子,其实也没什么技术含量,欢迎大伙拍砖.我设计的这个推送demo是基于ajax长轮询+msmq消息队列来实现的,具体交互过程如下图: 先说说这个ajax长轮询,多长时间才算长呢?这个还真不好界定.这里是相对普通ajax请求来说的,通常处理一个请求也就是毫秒级别的时间.但是这里的长轮询方式在ajax发送请求给服务器之后,服务器给调用端返回数据的时间多长那可还真不好说.嘿嘿,这关键要看我们啥时候往msmq队列中推送数据了,先看看推送的效果图吧..... 抱歉,没弄张

Android消息推送

1.推送方式基础知识:  在移动互联网时代以前的手机,如果有事情发生需要通知用户,则会有一个窗口弹出,将告诉用户正在发生什么事情.可能是未接电话的提示,日历的提醒,或是一封新的彩信.推送功能最早是被用于Email中,用来提示我们新的信息.由于时代的发展和移动互联网的热潮,推送功能更加地普及,已经不再仅仅用在推送邮件了,更多地用在我们的APP中了. 当我们开发需要和服务器交互的应用程序时,基本上都需要获取服务器端的数据,比如<地震应急通>就需要及时获取服务器上最新的地震信息.要获取服务器上不定时

[转]PhoneGap使用PushPlugin插件实现消息推送

本文转自:http://my.oschina.net/u/1270482/blog/217661 http://devgirl.org/2013/07/17/tutorial-implement-push-notifications-in-your-phonegap-application/ 概括 Android设备通过GCM服务来接收推送消息,而iOS设备这从苹果的APN服务获取.虽然按照负载来说这是两种不同的服务,但是证书都在从第三方接收消息的时候是需要作为一个存储和转发类型的服务.辨别接收

socket.io-直播视频的消息推送

近日接到需求,需要在"直播后台监控系统"里监控直播间的消息.刚接到需求时一脸懵逼,好在队友给力,Google强大,需求已经上线.现将我完成需求的过程与查阅了解到的知识整理出来,仅供参考,若错误请指教~~ 一.什么是WebSocket WebSocket一种在单个TCP连接上进行全双工通讯的协议.WebSocket通信协议于2011年被IETF定为标准RFC 6455,并被RFC7936所补充规范,WebSocketAPI被W3C定为标准. WebSocket 是独立的.创建在 TCP