百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 编程网 > 正文

golang 创建unix socket 服务(golang new struct)

yuyutoo 2025-03-24 01:15 6 浏览 0 评论

在go中,我们可以通过 net.Listen 创建一个socket服务,然后其他程序通过socket即可实现快速通信,具体示例如下(此处因golang的err错误处理,所以导致程序有些冗余;实际使用时可以忽略一些错误):

package main

import (
	"encoding/json"
	"fmt"
	"net"
	"os"
	"syscall"
)

// 程序入口文件
func main() {
	socket_file := "/tmp/go_main_self.sock"
	// 文件存在的话就删除
	if _, err := os.Stat(socket_file); err == nil {
		// 文件存在,删除该socket文件
		syscall.Unlink(socket_file)
	}
	// 创建一个socket文件
	socket, err := net.Listen("unix", socket_file)
	if err != nil {
		panic(err.Error())
	}
	// 关闭时删除socker文件
	defer syscall.Unlink(socket_file)
	fmt.Println("开始监听服务:", socket_file)
	// 无限循环受理请求
	for {
		// 连接socker文件
		client, err := socket.Accept()
		if err != nil {
			panic("socker连接错误")
		}
		// 读取内容
		buf := make([]byte, 2048)
		data_len, err := client.Read(buf)
		if err != nil {
			fmt.Println("读取失败:", err)
			continue
		}
		data := buf[0:data_len]
		fmt.Println("请求内容:", string(data))
		if len(data) > 0 {
			json_str, _ := json.Marshal(map[string]string{
				"content": string(data),
			})
			response := []byte(string(json_str))
			_, err = client.Write(response)
			if err != nil {
				fmt.Println("写入失败:", err)
			}
		}
	}
}

在PHP中,我们可以使用以下方法进行封装、调用

<?php
function sendSocket($msg = ""){
    // 创建 连接 发送消息 接收响应 关闭连接
    $socket = socket_create(AF_UNIX, SOCK_STREAM, 0);
    socket_connect($socket, '/tmp/go_main_self.sock');
    socket_send($socket, $msg, strlen($msg), 0);
    $response = socket_read($socket, 1024);
    socket_close($socket);
    return $response;
}

echo sendSocket("123123");
echo "\n";

运行示例:GO监听

$ go run main.go 
开始监听服务: /tmp/go_main_self.sock

# 运行后结果:
$ go run main.go 
开始监听服务: /tmp/go_main_self.sock
请求内容: 123123

运行示例:PHP脚本

$ php main.php
{"content":"123123"}

接下来,我们就可以根据请求、接受的方法进入不同的单元,进行不同的操作啦,比如将请求的数据整合成统一的json形式,如下:

{
    "func":"add",
    "data":{
        "param1":1,
        "param2":2
    }
}

在go中,我们也就可以直接根据func对象,去调用程序中的对应方法执行操作

相关推荐

Mysql和Oracle实现序列自增(oracle创建序列的sql)

Mysql和Oracle实现序列自增/*ORACLE设置自增序列oracle本身不支持如mysql的AUTO_INCREMENT自增方式,我们可以用序列加触发器的形式实现,假如有一个表T_WORKM...

关于Oracle数据库12c 新特性总结(oracle数据库19c与12c)

概述今天主要简单介绍一下Oracle12c的一些新特性,仅供参考。参考:http://docs.oracle.com/database/121/NEWFT/chapter12102.htm#NEWFT...

MySQL CREATE TABLE 简单设计模板交流

推荐用MySQL8.0(2018/4/19发布,开发者说同比5.7快2倍)或同类型以上版本....

mysql学习9:创建数据库(mysql5.5创建数据库)

前言:我也是在学习过程中,不对的地方请谅解showdatabases;#查看数据库表createdatabasename...

MySQL面试题-CREATE TABLE AS 与CREATE TABLE LIKE的区别

执行"CREATETABLE新表ASSELECT*FROM原表;"后,新表与原表的字段一致,但主键、索引不会复制到新表,会把原表的表记录复制到新表。...

Nike Dunk High Volt 和 Bright Spruce 预计将于 12 月推出

在街上看到的PandaDunk的超载可能让一些球鞋迷们望而却步,但Dunk的浪潮仍然强劲,看不到尽头。我们看到的很多版本都是为女性和儿童制作的,这种新配色为后者引入了一种令人耳目一新的新选择,而...

美国多功能舰载雷达及美国海军舰载多功能雷达系统技术介绍

多功能雷达AN/SPY-1的特性和技术能力,该雷达已经在美国海军服役了30多年,其修改-AN/SPY-1A、AN/SPY-1B(V)、AN/SPY-1D、AN/SPY-1D(V),以及雷神...

汽车音响怎么玩,安装技术知识(汽车音响怎么玩,安装技术知识视频)

全面分析汽车音响使用或安装技术常识一:主机是大多数人最熟习的音响器材,有关主机的各种性能及规格,也是耳熟能详的事,以下是一些在使用或安装时,比较需要注意的事项:LOUDNESS:几年前的主机,此按...

【推荐】ProAc Response系列扬声器逐个看

有考牌(公认好声音)扬声器之称ProAcTablette小音箱,相信不少音响发烧友都曾经,或者现在依然持有,正当大家逐渐掌握Tablette的摆位设定与器材配搭之后,下一步就会考虑升级至表现更全...

#本站首晒# 漂洋过海来看你 — BLACK&amp;DECKER 百得 BDH2000L无绳吸尘器 开箱

作者:初吻给了烟sco混迹张大妈时日不短了,手没少剁。家里有了汪星人,吸尘器使用频率相当高,偶尔零星打扫用卧式的实在麻烦(汪星人:你这分明是找借口,我掉毛是满屋子都有,铲屎君都是用卧式满屋子吸的,你...

专题|一个品牌一件产品(英国篇)之Quested(罗杰之声)

Quested(罗杰之声)代表产品:Q212FS品牌介绍Quested(罗杰之声)是录音监听领域的传奇品牌,由英国录音师RogerQuested于1985年创立。在成立Quested之前,Roger...

常用半导体中英对照表(建议收藏)(半导体英文术语)

作为一个源自国外的技术,半导体产业涉及许多英文术语。加之从业者很多都有海外经历或习惯于用英文表达相关技术和工艺节点,这就导致许多英文术语翻译成中文后,仍有不少人照应不上或不知如何翻译。为此,我们整理了...

Fyne Audio F502SP 2.5音路低音反射式落地音箱评测

FyneAudio的F500系列,有新成员了!不过,新成员不是新的款式,却是根据原有款式提出特别版。特别版产品在原有型号后标注了SP字样,意思是SpecialProduction。Fyne一共推出...

有哪些免费的内存数据库(In-Memory Database)

以下是一些常见的免费的内存数据库:1.Redis:Redis是一个开源的内存数据库,它支持多种数据结构,如字符串、哈希表、列表、集合和有序集合。Redis提供了快速的读写操作,并且支持持久化数据到磁...

RazorSQL Mac版(SQL数据库查询工具)

RazorSQLMac特别版是一款看似简单实则功能非常出色的SQL数据库查询、编辑、浏览和管理工具。RazorSQLformac特别版可以帮你管理多个数据库,支持主流的30多种数据库,包括Ca...

取消回复欢迎 发表评论: