golang demo grpc

aspnetcore微服务之间通信grpc，一般服务对外接口用restful架构，HTTP请求，服务之间的通信grpc多走内网。 以前写过一篇grpc和web前端之间的通讯，代码如下： exercisebook/grpc/grpc-web at main · liuzhixin405/exercis ......

package xlog import ( "bufio" "fmt" "github.com/sirupsen/logrus" rotatelogs "github.com/lestrrat-go/file-rotatelogs" "github.com/rifflock/lfshook" "os ......

go get github.com/spf13/viper config.toml title = "toml exaples" redis = "127.0.0.1:3300" [mysql] host = "192.168.1.1" ports = 3306 username = "root" ......

WaitGroup 主要用于控制任务组下的并发子任务。它的具体做法就是，子任务 goroutine 执行前通过 Add 方法添加任务数目，子任务 goroutine 结束时调用 Done 标记已完成任务数，主任务 goroutine 通过 Wait 方法等待所有的任务完成后才能执行后续逻辑 pack ......

go get github.com/go-xorm/xorm package main import ( "fmt" _ "github.com/go-sql-driver/mysql" "github.com/go-xorm/xorm" ) type PointInfo struct { Id i ......

搭建自定义返回值处理器demo 新建springboot项目 修改pom.xml <!-- 新增依赖 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</a ......

package main import ( "context" "encoding/json" "fmt" "github.com/elastic/go-elasticsearch/v7" "github.com/elastic/go-elasticsearch/v7/esapi" "log" ) ......

1. 简介 mpi_dec_test 是rockchip官方解码 demo 本篇文章进行mpi_dec_test 的代码解析，解码流程解析 2. 环境介绍 硬件环境： ArmSoM-W3 RK3588开发板 软件版本： OS：ArmSoM-W3 Debian11 3. mpp解码流程解析 mpp_c ......

前言 在国产麒麟系统上实现C++三维仿真，使用OSG技术，其他基于web的技术也是可以但是交互上鼠标拽托等交互相对差一些，所以这块需要斟酌选择到底是何种技术来取舍。 本篇在厂家指定的麒麟系统上编译OSG。 环境 系统版本：银河麒麟桌面操作系统V10(SP1)（注意：不对外提供） Gcc版本：gcc ......

package main import "fmt" // MyInt ~表示不仅支持int8, 还支持int8的衍生类型int8A和int8B type MyInt interface { int | ~int8 | int16 | int32 | int64 } func getMaxNum[T ......

首先新建Service，名称叫做server-api vim /lib/systemd/system/server-api.service [Unit] Description=server api [Service] Type=simple Restart=always RestartSec=5s ......

主要是体验下dart grpc 的集成试用,grpc 对于dart 的支持也是基于了插件生成代码，然后我们可以基于生成的代码创建实现，client 进行调用 参考项目 代码来自官方示例 proto 定义 syntax = "proto3"; option java_multiple_files = ......

运行环境 OS和Golang版本： go version go1.21.0 darwin/arm64 安装 源码安装 下载最新版本的源码，地址https://github.com/minio/minio后编译 cd minio go build main.go # 得到 116M Oct 19 15 ......

import ( "fmt" "sync" "time" ) type Task func() type ThreadPool struct { workerCount int taskQueue chan Task wg sync.WaitGroup } func NewThreadPool(wo ......

作者:张富春(ahfuzhang)，转载时请注明作者和引用链接，谢谢！ cnblogs博客 zhihu Github 公众号:一本正经的瞎扯 上次玩 golang 汇编是使用了一个 python 的 intel 汇编转换 plan9 汇编的工具，很不好用。 本次试试一些 golang 实现的工具。 ......

作者:张富春(ahfuzhang)，转载时请注明作者和引用链接，谢谢！ cnblogs博客 zhihu Github 公众号:一本正经的瞎扯 通常，可以通过命令行工具，来查看一个代码文件对应的汇编代码： go build -gcflags -S api.go // 或者 go tool compil ......

结构体数组与接口数组转换 如果想把[]struct转为[]interface，我们发现直接赋值会报错。 理论上interface可以转换任何数据，为什么结构体数组不可以呢？这是因为interface的设计导致的，如果能理解interface的底层实现，就能很清楚知道如何转换了。 如图所示，与C++的 ......

前言 之前我做 AIHub 的时候通过 gRPC 的方式接入了 ChatGLM 等开源大模型，对于大模型这块我搞了个 StarAI 框架，相当于简化版的 langchain ，可以比较方便的把各种大模型和相关配套组合在一起使用。 主要思路还是用的 OpenAI 接口的那套，降低学习成本，但之前为了快 ......

1，借助linux系统命令 /usr/bin/uuidgen 1.1 代码 package main import ( "fmt" "log" "os/exec" ) func main(){ out,err := exec.Command("uuidgen").Output() if err!=n ......

转，原文：https://www.jianshu.com/p/3b0b3a4c83da 数据库操作是一个应用必不可少的部分，但是我们很多时候对golang的sql包仅仅是会用，这是不够的。每一条语句的执行，它的背后到底发生了什么。各式各样对sql包的封装，是不是有必要的，有没有做无用功？ 这是go ......

转，原文： https://www.jianshu.com/p/807257fcb985?utm_campaign=studygolang.com&utm_medium=studygolang.com&utm_source=studygolang.com 当我们拿到一个DB实例之后就可以操作数据库了 ......

转，原文： https://www.jianshu.com/p/cd8cee3d7fc3 上一章中我们一起探讨了golangdatabase/sql包中如何获取一个真实的数据库连接。当我们拿到一个数据库连接之后就可以开始真正的数据库操作了。本章讲继续深入，一起探讨底层是如何进行数据库操作的。 上一章 ......

前言 前段时间写过一篇 gRPC 的入门文章，在最后还留了一个坑没有填： 也就是 gRPC 的负载均衡问题，因为当时的业务请求量不算大，再加上公司没有对 Istio 这类服务网格比较熟悉的大牛，所以我们也就一直拖着没有解决，依然只是使用了 kubernetes 的 service 进行负载，好在也没 ......

websocket简易demo 网上找的然后写的demo 还有一种写法，跟这种写法不同，先记录这一种 引入依赖 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-webso ......

spring 状态机demo <dependency> <groupId>org.springframework.statemachine</groupId> <artifactId>spring-statemachine-core</artifactId> <version>2.0.1.RELEA ......

package com.chen.scanner; import java.util.Scanner; public class Demo04 { public static void main(String[] args) { Scanner scanner = new Scanner(Syste ......

package com.chen.scanner; import java.util.Scanner;public class Demo05 { public static void main(String[] args) { //我们可以输入多个数字，并求其总和与平均数，每输入一个数字用回车确认， ......

typedef int Position; typedef struct LNode *List; struct LNode { ElementType Data[MAXSIZE]; Position Last; }; /* 初始化 */ List MakeEmpty() { List L; L = ......

生产者 package main import ( "fmt" "github.com/streadway/amqp" "strconv" "time" ) // 启动生产者，n秒之内，如果consume没有消费，那么就会被die-死信队列消费 func main() { // # 1.创建连接 m ......

gRPC简单介绍 gRPC 是一种与语言无关的高性能远程过程调用 (RPC) 框架（google开源的rpc框架）。gRPC 默认使用 protocol buffers，这是 Google 开源的一套成熟的结构数据序列化机制（也可以使用其他数据格式如 JSON） gRPC 的主要优点是： HTTP2 ......