消息golang kafka
PHP开发实时聊天系统的消息重发和消息过期处理策略
PHP开发实时聊天系统的消息重发和消息过期处理策略 随着互联网的普及和技术的发展，实时聊天系统成为了现代人们日常生活中不可或缺的一部分。在开发实时聊天系统的过程中，消息的可靠发送以及过期处理成为了重要的问题。本文将介绍如何使用PHP开发实时聊天系统，并提供了消息重发和消息过期处理的策略以及相关代码示 ......
Golang 面向对象深入理解
1 封装 Java 中封装是基于类（Class），Golang 中封装是基于结构体（struct） Golang 的开发中经常直接将成员变量设置为大写使用，当然这样使用并不符合面向对象封装的思想。 Golang 没有构造函数，但有一些约定俗成的方式： 提供 NewStruct(s Struct) * ......
Flink消费kafka数据同步问题排查
Flink消费kafka数据同步问题排查 https://mp.weixin.qq.com/s/EZbCKHBI_JrsF0yJndhe8Q Flink消费kafka数据同步问题排查 原创 任天兵 哈啰技术 2023-10-31 17:31 发表于上海 我们有一个flink任务，消费的kafka的数 ......
golang常用json库的选择
Sonic 如果对性能要求非常高，可以使用Sonic。但是Sonic有一些要求，高性能必然带来特例化，官方也介绍了，对CPU架构和系统等都有要求。其底层使用了一些汇编和c的代码实现，所以如果不是对性能要求特别高，可以不用。 fastjson fastjson介绍就是非常快，不过功能相对较少。好久已经 ......
Rabbitmq消息队列：linux服务器上部署Rabbitmq服务
一、服务器安装中间件 此处使用的是CentOS 7系统。 1、安装Erlang运行环境 下载安装包： wget https://packages.erlang-solutions.com/erlang-solutions-1.0-1.noarch.rpm 安装相关的依赖（不安装依赖而直接安装erla ......
关于语音消息转文字能力下线的通知
关于语音消息转文字能力下线的通知 微信公众平台将于2023年11月1日下线语音消息转文字能力。届时，用户发送的语音消息将不再自动转为文字内容。若开发者开通了语音识别，微信推送的语音消息体中，不再返回Recongnition字段（查看开发文档）。为避免影响用户使用，请开发者在下线前尽快调整接口。如有疑 ......
企业微信客服语音消息事件仅支持amr格式文件
读取消息 当微信客户、接待人员发消息或有行为动作时，企业微信后台会将事件的回调数据包发送到企业指定URL；企业收到请求后，再通过读取消息接口主动读取具体的消息内容。 微信客户发送的消息、接待人员在企业微信回复的消息、发送消息接口发送失败事件（如被用户拒收）、客户点击菜单消息的回复消息，可以通过该接口 ......
golang gin框架使用endless实现热更新原理和操作步骤
最近在学习go的Gin Web Framework，其中一个知识点是：【优雅地重启或停止】，原文截图： 这里说的其中一个方法是使用【fvbock/endless】是实现，记录下自己的实操步骤！ Gin Web Framework文档地址：https://gin-gonic.com/zh-cn/doc ......
kafka了解多少，遇到哪些故障，怎么解决的？
作为一种分布式消息队列，Kafka 在实际应用中也可能遇到各种故障，下面列举几种常见的情况和解决方案： 1. 节点宕机 当 Kafka 集群中的某个节点宕机时，可能导致数据不一致、数据丢失等问题。解决方案建议使用多副本机制，即在各个节点之间进行数据的同步和复制，保证集群中的节点宕机时，数据不会丢失。 ......
哪些情况下需要使用消息队列？
应用解耦：当多个应用程序需要共享数据或资源时，消息队列可以作为中介传递消息，减少程序之间的依赖。 异步处理：当一个任务需要很长时间才能完成，那么可以将任务处理过程分为两步：首先将任务放入消息队列中，然后由另一个线程从队列中取出并处理该任务。这种方式允许主程序等待长时间操作的同时处理其他任务。 流量削 ......
Golang中log日志包的使用(转)
1.前言 作为后端开发人员，日志文件记录了发生在操作系统或其他软件运行时的事件或状态。技术人员可以通过日志记录进而判断系统的运行状态，寻找导致系统出错、崩溃的成因等。这是我们分析程序问题常用的手段。 2.log包介绍 在Golang中记录日志非常方便，Golang提供了一个简单的日志记录包log，包 ......
Kafka-生产者性能调优
（一）参数调优 参数调优相关代码 在实际的kafka开发中，我们会发现，无论是生产者还是消费者，都需要构建一个Properties对象，里面设置了很多参数。在这段代码中有很多常用的参数配置，在线上使用时，我们要根据实际的数据量和数据大小来决定这些配置的具体值。 Properties props = ......
通过小程序向用户发送模板消息
方法：公众号申请开启模板消息功能，并且申请一个模板。然后，通过微信的网站API获取AccessToken，通过AccessToken给指定用户发送模板消息。 关键问题：公众号下用户的openid和小程序下用户的openid是不同的。因此，需要在数据库里把每个用户的unionid存起来，然后join查 ......
Kafka-生产者、broker、消费者的调优参数总结
生产环境下，为了尽可能提升Kafka的整体吞吐量，可以对Kafka的相关配置参数进行调整，以达到提升整体性能的目的。 本文主要从Kafka的不同组件出发，讲解各组件涉及的配置参数和参数含义。 一、生产者（producer.properties或者代码中） 1、acks：Producer需要Leade ......
golang flag的使用
package main import ( "backend-service-api-scripts/utils" "database/sql" "flag" "fmt" "log" "os" ) var ( db *sql.DB = utils.ConnectData() // 这里的连接数据库需 ......
dotnet core 3.1 将 UWP 控件嵌入到 WPF 应用 收到 UIA 消息主线程卡住
本文记录一个问题，此问题是在 .NET Core 3.1 的 WPF 应用里面，嵌入 UWP 控件之后，在收到 UIA 的消息时，可能让主线程卡住。暂时此问题还不知道具体的复现步骤，此问题不确定是否真的和 WPF 或 UWP 相关，此问题可能仅仅只是 UIA 模块的问题 此问题没有在 dotnet ......
打印空心金字塔_Golang实现
* * * * * * * * * * * * * * * * * * * * * * * * 需求：在控制台打印如上图所示的效果图 解题思路： 首先简化问题，先打印出实心金字塔，然后可观察得知，层数与star（星号）数量保持着一定关系（奇数队列），1、3、5、7……2n-1 然后，格式化打印效果， ......
Golang后端大厂面经！
大家好，我是阳哥。专注Go语言的学习经验分享和就业辅导。 之前分享了很多 Golang 后端的大厂面经，不少同学在催更新，这篇给大家继续安排。 本文来自一位同学的投稿，面试深X服的面经汇总，前半部分主要是Go语言相关，后半部分也涉及微服务和Redis。 Slice扩容 slice切片扩容机制？为什么 ......
php 小程序信息推送公众号消息模版
1.登录公众号，新建消息推送模版 2.打开微信官方文档 ->找到模版消息接口 https://developers.weixin.qq.com/doc/offiaccount/Message_Management/Template_Message_Interface.html 3. 代码 /** * ......
Kafka基础学习笔记
一、Kafka： 1、简介： Kafka是由Apache开源，具有分布式、分区的、多副本的、多订阅者，基于Zookeeper协调的分布式处理平台，由Scala和Java语言编写。最大的特性就是可以实时并高速的处理大量数据来满足需求，同时对消息数据进行持久化存储。 2、优点： Kafka与其他消息队列 ......
kafka代码实践
安装kafka： Windows安装kafka, 详情见：https://blog.csdn.net/sinat_32502451/article/details/133067851 Linux 安装kafka，详情见：https://blog.csdn.net/sinat_32502451/art ......
kafka代码示例
安装kafka： Windows安装kafka, 详情见：https://blog.csdn.net/sinat_32502451/article/details/133067851 Linux 安装kafka，详情见：https://blog.csdn.net/sinat_32502451/art ......
一个轻量级golang ORM框架gdbcTemplate
今天介绍一个自己写的轻量级golang ORM框架gdbcTemplate, 目前支持mysql, postgresql等数据库 项目地址位于 https://github.com/guoapeng/gdbctemplate 以下摘自readme文件, 里面有示例供参考. 1. readme fil ......
golang 中使用 writev (sendmsg) 系统调用来一次发送多块数据
作者:张富春(ahfuzhang)，转载时请注明作者和引用链接，谢谢！ cnblogs博客 zhihu Github 公众号:一本正经的瞎扯 writev，或者说 sendmsg 等系统调用，能够发送多个数据块。从节约系统调用次数的角度说，这个 api 非常好。 下面演示如何在 golang 中使用 ......
NetCore之基于Azure Service Bus的消息服务
什么是Azure服务总线？ Azure服务总线是完全托管的企业消息代理，包括消息队列和发布订阅(命名空间). Service Bus通常被用来解耦应用程序和服务，控制跨服务和应用程序间安全路由和传输数据。 本篇从实战出发介绍如何通过Service Bus发送接收及消费消息。 1、创建API.Azur ......
云端golang开发，无需本地配置，能上网就能开发和运行
不想装golang，不想装IDE，还想有个流畅的运行环境，最重要的是一分钱都不想花，嗯嗯，GitHub云开发环境全部满足你，一切操作尽在本文 ......
Kafka 在分布式系统中的 7 大应用场景
Kafka 介绍 Kafka 是一个开源的分布式流式平台，它可以处理大量的实时数据，并提供高吞吐量，低延迟，高可靠性和高可扩展性。Kafka 的核心组件包括生产者（Producer），消费者（Consumer），主题（Topic），分区（Partition），副本（Replica），日志（Log）， ......
MQTT——具有.NET Core的消息队列遥测传输协议
转自：https://blog.csdn.net/mzl87/article/details/109910991 目录 介绍 什么是MQTT REST是什么？ 体系结构 有效载荷 安全 代码样例 代理 发布者 订阅者 执行 概要 Git存储库链接 参考文献 介绍 发布/订阅模式是解耦软件的常见要求。 ......
golang 获取 mongo 数据库状态
命令行模式 navicat golang package main import ( "context" "encoding/json" "fmt" "log" "go.mongodb.org/mongo-driver/bson" "go.mongodb.org/mongo-driver/mongo ......