第1章 Kafka概述 1.1 消息队列 1)点对点模式(一对一,消费者主动拉取数据,消息收到后消息清除) 点对点模型通常是一个基于拉取或者轮询的消息传送模型,这种模型从队列中请求信息,而不是将消息推送到客户端。这个模型的特点是发送到队列的消息被一个且只有一个接收者接收处理,即使有多个消息监听者也是 ...
分类:
其他好文 时间:
2020-05-30 19:39:36
阅读次数:
63
Kafka最初考虑的问题是,customer应该从brokes拉取消息还是brokers将消息推送到consumer,也就是pull还push。在这方面,Kafka遵循了一种大部分消息系统共同的传统的设计:producer将消息推送到broker,consumer从broker拉取消息。 一些消息系 ...
分类:
其他好文 时间:
2020-05-27 09:22:10
阅读次数:
405
一、实现功能:当前页面点击请求后,另一个页面立即收到一条消息,用springboot+websocket+rabbitMQ实现。 二、java代码: 1、先在pom里导入需要的坐标 <!--rabbitMQ--> <dependency> <groupId>org.springframework.b ...
分类:
Web程序 时间:
2020-05-25 12:25:54
阅读次数:
131
一、 现象 用户打开消息推送有概率报错,后续发现推送消息阅读数、点赞数无法正常更新,mysql报警有行锁, DBA抓到有锁表语句,kill该语句未正常恢复,elk日志有大量的java.sql.SQLException: connection holder is null 重启应用恢复 二、分析 根据 ...
分类:
其他好文 时间:
2020-05-23 16:53:18
阅读次数:
50
越来越多的项目需要用到实时消息的推送与接收,怎样用PHP实现最方便呢?我这里推荐大家使用GoEasy, 它是一款第三方推送服务平台,使用它的API可以轻松搞定实时推送! 浏览器兼容性:GoEasy推送 支持websocket 和polling两种连接方式,从而可以支持IE6及其以上的所有版本,同时还 ...
分类:
Web程序 时间:
2020-05-23 14:43:10
阅读次数:
76
/** * 获取用户的openid * * @param int $uid 用户id * * @return mixed|string * * @throws ServiceException */public static function getOpenId(int $uid){ if (!$u ...
分类:
微信 时间:
2020-05-18 20:25:30
阅读次数:
135
伴随着中国移动互联网的快速发展、直播出现、短视频的飞快发展壮大,大家的生活方式也在产生着变动:从报刊、杂志期刊、广播电台到现如今的互联网上的新闻报道消息推送,这正表明了一个状况,大家从文字阅读渐渐地的变化为图片阅读甚至视频阅读,如同企鹅智酷中《2019中国互联网趋势报告》中叙述的“视频对图片/文本的侵蚀还将不断并极有可能加快,在新网民中,视频可能是她们接触互联网的第一物质。”这充分证明了可视化在这
分类:
其他好文 时间:
2020-05-15 18:00:07
阅读次数:
168
手把手的教您用GoEasy在微信小程序里,最短的时间快速实现一个websocket即时通讯Demo。
分类:
微信 时间:
2020-05-11 15:09:08
阅读次数:
83
前言 如果我们希望为自己的网站增添微信扫码收款功能,用于收取一些服务费用,为个人网站提供自动化有偿服务的话,那我们有哪些方案呢? ?首先,我们先看下效果,以下是服务端的收款二维码的发起示例演示: 其次,我们再看看手机端 微信扫码支付的演示: 我们手机端会将收款的消息推送到服务器API。其中接口信息定 ...
分类:
微信 时间:
2020-05-10 01:38:32
阅读次数:
118
App接口消息推送我们在使用手机app时,会时不时收到app的推送,今天我们就来看看消息推送怎么实现的。消息推送的方式使用轮询的方法获取推送消息。我们的app每隔1一分钟就发送一个http请求,请求我们的服务器,我们服务器返回推送的消息。(类似于js中setinterval函数设置每隔几秒钟发送ajax)使用第三方平台进行推送这里我们使用极光推送1我们先注册登录2进入控制台,创建应用,我们能拿到a
分类:
移动开发 时间:
2020-05-05 21:52:29
阅读次数:
197