jjzjj

go - 从列表中删除客户端会终止其他连接

coder 2024-07-10 原文

为什么要杀死一个简单的“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/

go从34clientsection

有关go - 从列表中删除客户端会终止其他连接的更多相关文章

  1. ruby - 其他文件中的 Rake 任务 - 2

    我试图在一个项目中使用rake，如果我把所有东西都放到Rakefile中，它会很大并且很难读取/找到东西，所以我试着将每个命名空间放在lib/rake中它自己的文件中，我添加了这个到我的rake文件的顶部:Dir['#{File.dirname(__FILE__)}/lib/rake/*.rake'].map{|f|requiref}它加载文件没问题，但没有任务。我现在只有一个.rake文件作为测试，名为“servers.rake”，它看起来像这样:namespace:serverdotask:testdoputs"test"endend所以当我运行rakeserver:testid时

  2. ruby - 如何将脚本文件的末尾读取为数据文件(Perl 或任何其他语言) - 2

    我正在寻找执行以下操作的正确语法(在Perl、Shell或Ruby中):#variabletoaccessthedatalinesappendedasafileEND_OF_SCRIPT_MARKERrawdatastartshereanditcontinues. 最佳答案 Perl用__DATA__做这个:#!/usr/bin/perlusestrict;usewarnings;while(){print;}__DATA__Texttoprintgoeshere 关于ruby-如何将脚

  3. ruby-on-rails - 如何从 format.xml 中删除 <hash></hash> - 2

    我有一个对象has_many应呈现为xml的子对象。这不是问题。我的问题是我创建了一个Hash包含此数据，就像解析器需要它一样。但是rails自动将整个文件包含在.........我需要摆脱type="array"和我该如何处理？我没有在文档中找到任何内容。 最佳答案 我遇到了同样的问题；这是我的XML:我在用这个:entries.to_xml将散列数据转换为XML，但这会将条目的数据包装到中所以我修改了:entries.to_xml(root:"Contacts")但这仍然将转换后的XML包装在“联系人”中，将我的XML代码修改为

  4. ruby - 我可以使用 Ruby 从 CSV 中删除列吗？ - 2

    查看Ruby的CSV库的文档，我非常确定这是可能且简单的。我只需要使用Ruby删除CSV文件的前三列，但我没有成功运行它。 最佳答案 csv_table=CSV.read(file_path_in,:headers=>true)csv_table.delete("header_name")csv_table.to_csv#=>ThenewCSVinstringformat检查CSV::Table文档:http://ruby-doc.org/stdlib-1.9.2/libdoc/csv/rdoc/CSV/Table.html

  5. ruby - 续集在添加关联时访问many_to_many连接表 - 2

    我正在使用Sequel构建一个愿望list系统。我有一个wishlists和itemstable和一个items_wishlists连接表(该名称是续集选择的名称)。items_wishlists表还有一个用于facebookid的额外列(因此我可以存储opengraph操作)，这是一个NOTNULL列。我还有Wishlist和Item具有续集many_to_many关联的模型已建立。Wishlist类也有:selectmany_to_many关联的选项设置为select:[:items.*,:items_wishlists__facebook_action_id].有没有一种方法可以

  6. ruby - RVM 使用列表[0] - 2

    是否有类似“RVMuse1”或“RVMuselist[0]”之类的内容而不是键入整个版本号。在任何时候，我们都会看到一个可能包含5个或更多ruby的列表，我们可以轻松地键入一个数字而不是X.X.X。这也有助于rvmgemset。 最佳答案 这在RVM2.0中是可能的=>https://docs.google.com/document/d/1xW9GeEpLOWPcddDg_hOPvK4oeLxJmU3Q5FiCNT7nTAc/edit?usp=sharing-知道链接的任何人都可以发表评论

  7. ruby - 我可以使用 aws-sdk-ruby 在 AWS S3 上使用事务性文件删除/上传吗？ - 2

    我发现ActiveRecord::Base.transaction在复杂方法中非常有效。我想知道是否可以在如下事务中从AWSS3上传/删除文件:S3Object.transactiondo#writeintofiles#raiseanexceptionend引发异常后，每个操作都应在S3上回滚。S3Object这可能吗？？ 最佳答案 虽然S3API具有批量删除功能，但它不支持事务，因为每个删除操作都可以独立于其他操作成功/失败。该API不提供任何批量上传功能(通过PUT或POST)，因此每个上传操作都是通过一个独立的API调用完成的

  8. ruby - 无法在 60 秒内获得稳定的 Firefox 连接 (127.0.0.1 :7055) - 2

    我使用的是Firefox版本36.0.1和Selenium-Webdrivergem版本2.45.0。我能够创建Firefox实例，但无法使用脚本继续进行进一步的操作无法在60秒内获得稳定的Firefox连接(127.0.0.1:7055)错误。有人能帮帮我吗？ 最佳答案 我遇到了同样的问题。降级到firefoxv33后一切正常。您可以找到旧版本here 关于ruby-无法在60秒内获得稳定的Firefox连接(127.0.0.1:7055)，我们在StackOverflow上找到一个类

  9. ruby - 调用其他方法的 TDD 方法的正确方法 - 2

    我需要一些关于TDD概念的帮助。假设我有以下代码defexecute(command)casecommandwhen"c"create_new_characterwhen"i"display_inventoryendenddefcreate_new_character#dostufftocreatenewcharacterenddefdisplay_inventory#dostufftodisplayinventoryend现在我不确定要为什么编写单元测试。如果我为execute方法编写单元测试，那不是几乎涵盖了我对create_new_character和display_invent

  10. ruby - 如何安全地删除文件？ - 2

    在Ruby中是否有Gem或安全删除文件的方法？我想避免系统上可能不存在的外部程序。“安全删除”指的是覆盖文件内容。 最佳答案 如果您使用的是*nix，一个很好的方法是使用exec/open3/open4调用shred:`shred-fxuz#{filename}`http://www.gnu.org/s/coreutils/manual/html_node/shred-invocation.html检查这个类似的帖子:Writingafileshredderinpythonorruby?

随机推荐