- xml - AJAX/Jquery XML 解析
- 具有多重继承的 XML 模式
- .net - 枚举序列化 Json 与 XML
- XML 简单类型、简单内容、复杂类型、复杂内容
为什么要杀死一个简单的“ClientList.Remove(entry)”所有来自其他客户端的连接?
我有一个非常简单的 Go TCP 服务器,可以进行连接处理和登录处理。之后,如果创建一个客户端并使用 TCP 客户端启动一个 GO Routine。
newClient := &Client{"", "", login.LoginToken, conn}去 ClientReader(newClient)ClientList.PushBack(*newClient)
Go 例程读取所有传入数据。当连接超时或网络发生变化时(客户端获得新 IP)它将客户从客户列表中删除。
但是当它从列表中删除客户端时......所有其他客户端连接都死了?在循环中它找到正确的客户端并将其删除。
看看removeloop:
常规:
func ClientReader(client *Client) {
buffer := make([]byte, 2048)
for {
bytesRead, error := client.Conn.Read(buffer)
if error != nil {
Log(error)
break
}
var m Message
err := json.Unmarshal([]byte(buffer[0:bytesRead]), &m)
if err != nil {
Log(err)
} else {
switch m.Cmd {
case "Message":
case "Ping":
Log("Ping from: ", client.Name, " on ", client.Conn.RemoteAddr())
client.Conn.SetDeadline(time.Now().Add(25 * time.Second))
pong := []byte(`{"PONG":"..."}` + "\r\n")
client.Conn.Write(pong)
Log("PONG: " + time.Now().Format(time.RFC850))
Log("User Online: " + strconv.Itoa(ClientList.Len()))
Log("Goroutines: " + strconv.Itoa(runtime.NumGoroutine()))
default:
Log("Not supported Command: ", m.Cmd)
clienterror := []byte(`{"Err":"Command not supported"}` + "\r\n")
client.Conn.Write(clienterror)
}
for i := 0; i < 2048; i++ {
buffer[i] = 0x00
}
}
}
RemoveLoop:
for entry := ClientList.Front(); entry != nil; entry = entry.Next() {
listclient := entry.Value.(Client)
if client.Conn.RemoteAddr() == listclient.Conn.RemoteAddr() {
ClientList.Remove(entry)
Log("## SEARCH: ", client.Name, client.Conn.RemoteAddr())
Log("## FOUND: ", listclient.Name,listclient.Conn.RemoteAddr())
Log("## REMOVED: ", entry.Value)
break RemoveLoop
}
}
Log("Exit Client Reader Routine ", client.Name, " on ", client.Conn.RemoteAddr())
}
最佳答案
感谢您的快速回答:)我已经提出了您的建议(线程安全的 clientList),但我的问题仍然存在。
在测试和一些重写之后,我在服务器日志中看到了一件非常疯狂的事情。
在 ServerStart 之后它有 4 个 Goroutines .... 没问题。 (Golang 实习生例程?)
客户端 1 登录...并且 Goroutine 5 已启动...正常(第一个 ClientReader)客户端 2 登录...并且 Goroutine 6 已启动...正常(第二个 ClientReader)
客户端 2 是一部手机,我在手机和 WLAN 之间随机切换。
服务器检测到来自电话的 ip 更改...没问题。手机使用新的 IP 地址登录,并且服务器在 ConnectionTimout 后终止旧的连接......是好的。
在从手机发出 2-n 次 ping 后,服务器将 Goroutines 从 6 个增加到 7 个,手机失去了连接?
Goroutine 不是 Clientreader(它记录每个 START 和 EXIT)Clientreader 是我代码中唯一的 Goroutine。
GOLANG 在做什么,为什么会有一个 7 号协程?
关于go - 从列表中删除客户端会终止其他连接,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/20198611/
如果我终止应用程序,我在尝试保持我的功能运行时卡住了。 是否可以在应用程序未运行时保持核心位置(地理围栏/地理定位)和核心蓝牙运行?如果可能如何解决我的问题?我已经检查了背景模式,并实现了核心定位方法
该程序要求用户输入一个数字,然后从列表中返回详细信息。我该怎么做? do { Scanner in = new Scanner(System.in);
我正在开发一个内部分发的 iOS 应用程序(即,没有应用程序商店),我希望能够以恒定的 10 分钟间隔报告设备的位置。 无论如何,我在我的 plist 中包含了 location 作为字段 UIBac
我的 mongodb 服务器突然收到信号 15(终止)。我不知道为什么 mongodb 崩溃了。以下是日志消息。 Mon Jun 27 07:33:31.701 [signalProcessingTh
我按顺序运行了一堆malloc,并且每次都检查以确保它是成功的。像这样: typedef struct { int *aray; char *string; } mystruct; m
这个问题已经有答案了: How to stop a running pthread thread? (4 个回答) 已关闭 8 年前。 可以使用 pthread_join() 停止线程。但让我们想象一
#include #include #include struct node{ char data; int p; struct node *ptr; }; struct node *st
这个问题已经有答案了: Why should I use a semicolon after every function in javascript? (9 个回答) 已关闭 8 年前。 好吧,我问
我有一个启动多个工作线程的函数。每个工作线程都由一个对象封装,该对象的析构函数将尝试加入线程,即调用if (thrd_.joinable()) thrd_.join();。但是,每个 worker 必
我正在实现一个应用程序,当用户摇动手机时,该应用程序会监听并采取行动。 所以我实现了以下服务: public class ShakeMonitorService extends Service {
我在使用 Xcode 时遇到问题,其中弹出错误“Source Kit Service Terminated”,并且所有语法突出显示和代码完成在 Swift 中都消失了。我怎样才能解决这个问题? 这是一
我想为我的控制台应用程序安全退出,该应用程序将使用单声道在 linux 上运行,但我找不到解决方案来检测信号是否发送到它或用户是否按下了 ctrl+c。 在 Windows 上有内核函数 SetCon
关键: pthread_cancel函数发送终止信号pthread_setcancelstate函数设置终止方式pthread_testcancel函数取消线程(另一功能是:设置取消点) 1 线程取消
下面的程序在不同的选项级别下有不同的行为。当我用 -O3 编译它时,它永远不会终止。当我用 -O0 编译它时,它总是很快就会终止。 #include #include void *f(void *
我有 3 个节点的 K8S 集群,我创建了 3 个副本 pod,应用程序 app1 在所有 pod 上运行,我通过运行 service yaml 文件建立了服务,我可以看到通过运行 kubectl g
我打算使用 nginx 来代理 websocket。在执行 nginx reload/HUP 时,我知道 nginx 等待旧的工作进程停止处理所有请求。然而,在 websocket 连接中,这可能不会
在 Ubuntu 9.10 上使用 PVM 3.4.5-12(使用 apt-get 时的 PVM 包) 添加主机后程序终止。 laptop> pvm pvm> add bowtie-slave add
我编写了一个应用程序来从 iPhone 录制视频。它工作正常,但有一个大问题。当 AVCaptureSession 开始运行并且用户尝试从其库(iPod)播放音频时。此操作将使 AVCaptureSe
我将如何使用NSRunningApplication?我有与启动应用程序相反的东西: [[NSWorkspace sharedWorkspace] launchApplication:appName]
我正在使用 NSTask 执行一系列长时间运行的命令,如下所示: commandToRun = @"command 1;command2"; NSArray *arguments = [NSArray
我是一名优秀的程序员,十分优秀!