处理 Tcp 客户端和 Tcp 服务器的 Grails 问题

Posted 2023-03-31

【中文标题】处理 Tcp 客户端和 Tcp 服务器的 Grails 问题

【英文标题】：Grails Issue Dealing With Tcp Client & Tcp Server

【发布时间】：2011-01-21 01:21:33

【问题描述】：

不久前我在 Groovy 中创建了一个 Tcp 客户端和 Tcp 服务器，但没有遇到任何问题。当时我只连接到一台机器来收集数据。这次我试图连接到多个主机上的脚本，它只在我的 grails 应用程序中保存了一个主机信息。

我的 Grails 应用程序很简单，它有一个机器域类（基本上是我寻找的计算机及其上的信息），它将使用我的 TcpClient.groovy 脚本连接并从 TcpServer.groovy 上收集信息其他电脑。对于每个主机，它应该保存收集到的信息，但是，它似乎跳过了保存除最后一个主机之外的任何主机。

Tcp 客户端：

//TCP CLIENT    

public void queryData(def hosts) 

 for(int aHost = 0; aHost < hosts.size; aHost++) 
         cristalClient(hosts[aHost]);
 



public void cristalClient(String host) 

 commands = ["dateScan", "computerName", "ip", "quit"]

 answers = [commands.size]

 requestSocket = new Socket(host, 2000)

 r = new BufferedReader(new InputStreamReader(requestSocket.getInputStream()));
 w = new BufferedWriter(new OutputStreamWriter(requestSocket.getOutputStream()));

 String message = "Connection was successful"

 message = readAvailable(r)
 println("Sever>" + message)

 for(int n = 0; n < commands.size; n++) 
     sendMessage(commands[n]);
 answers[n] = readAvailable(r)
 

 lastRead = answers[0]
 machineName = answers[1]
 ipAddress = answers[3]

 w.flush()
 w.close()



public String readAvailable(r) 

    String out = ""
    String dum = null

    while((dum = r.readLine()) !=null) 
        if(dum == ">>EOF<<") return out
        if(out.length() > 0) out += "\r\n"
            out += dum
    
    return out



public void sendMessage(msg) 
    w.write(msg+"\r\n");
    w.flush();
    println("Client>" + msg);




public void printData(abc) 

    abc.eachWithIndex  it, index ->
    println "Drive $index"
    it.each  k, v ->
        println "\t$k = $v"
    
    

Tcp 服务器：

//TCP Server

def server = new ServerSocket(2000)

println("Waiting for connection")

    server.accept()  socket ->
        socket.withStreams  input, output ->   

            w = new BufferedWriter(new OutputStreamWriter(output))

            String message = "Connection was successful"

            r = new BufferedReader(new InputStreamReader(input))

            while(true) 

                if(message != null) 
                    sendMessage(message)
                    message = null
                

                String a = r.readLine()

                if(a == "dateScan") 
            message = new Date
         else if(a == "computerName") 
            message = InetAddress.getLocalHost().hostName
         else if(a == "ip") 
            message = InetAddress.getLocalHost().getHostAddress()           
                 else if(a == "quit") 
                    server.close()
                    return
                 else                     
                    message = "$a command unknown."
                    println message
                
            
        
    


def sendMessage(String msg) 
    println( "sending: >" + msg + "<" )
    w.writeLine(msg)
    w.writeLine(">>EOF<<")
    w.flush();
 

Grails 控制器：

//Grails Controller

CollectMachines 

    def w = new tcpClient()
    def hosts = ["winXp", "Win7"]

    w.queryData(hosts)
    def abc = w.hardDrive
    abc.each  println it 

    int numberOfDrives = abc.size()

    //add new machine 
    numberOfDrives.times 

        def machineName = abc.computerName[it]
        def machineInstance = Machine.findByMachineName(machineName)

        if (!machineInstance) 
            machineInstance = new Machine(machineName)
        

        def lastScan = abc.lastScan[it]                                
        def scanDate = new Date().parse("E MMM dd H:m:s z yyyy", lastScan)

        def ipAddress = abc.ipAddress[it]                              

        machineInstance.setIpAddress(ipAddress)                     
        machineInstance.setDateScanned(scanDate)                    
        machineInstance.save()                                      

    
    redirect(action: "list")

我是否需要暂停以便服务器有时间发送响应？我的 Tcp 客户端确实发送了所有命令，但只收到最后一组命令的响应。

另外，对于我的代码 sn-ps 的缩进问题，我不知道为什么会搞砸。

.

【参考方案1】：

您的代码存在一些问题。例如，tcpClient 从不分配给hardDrive。假设这是一个疏忽，我认为真正的问题是 tcpClient 正在查询多个主机的数据，并将所有结果存储在相同的实例变量answers，最终存储在lastRead、machineName 和ipAddress 中。

您需要分别存储每个主机的结果。一种方法是让answers 成为列表映射。例如，answers[host][0] 将是给定主机的第一个答案。

我认为没有必要暂停。

【讨论】：

抱歉，我不小心取出了将数据推送到硬盘的代码。我试图精简代码并删除不必要的源。我认为您对每个主机的地图是正确的，我会实施并回发。

不幸的是，我要到下周才能对此进行测试。我不确定您是否能够对此进行测试，但我会发布我想出的替代代码，也许您可​​以提及您认为它是否应该工作。 （我只会贴出TcpClient和Controller，因为用到了硬盘列表，我也会添加进去）

我不确定为什么我从来没有回来发布我的进度。然而，我找到了一种让它工作的方法，但在我看来它相当慢并且重复了不必要的功能。我在按照您之前提到的方式执行此操作时遇到问题，因为有些机器具有多个 IP 地址或其他信息，因此如果我有基于主机的列表映射，它们将被覆盖并丢失。我觉得将所有信息放在列表或地图中然后将信息添加到数据库中的任何其他建议都比基于主机循环多次将信息添加到数据库中更快。