使用Groovy进行Socket编程之－字节数组版

服务端代码：

import java.net.ServerSocket

class TestSocketServer {
	static server

	static {
		server = new ServerSocket(6666)
	}
	static main(args) {
		println "SOCKET测试服务已启动，运行于端口6666，请勿关闭此窗口。。。。"
		
		while(true) {
			server.accept { socket ->
				println "\n========================================\n${new Date().format('yyyy-MM-dd HH:mm:ss')} 正在处理请求..."
				socket.withStreams { input, output ->

					byte[] msgBody = new byte[2000];
					input.read(msgBody, 0, 2000);
					def msg = new String(msgBody, 'GBK').trim()
					println "${new Date().format('yyyy-MM-dd HH:mm:ss')} 接收到的消息: \n========================================\n$msg"

					output << "服务器处理时间：" + new Date().format('yyyy-MM-dd HH:mm:ss') + "\n" + msg
					socket.shutdownOutput()
				}
				println "${new Date().format('yyyy-MM-dd HH:mm:ss')} 处理完毕！\n========================================"
			}
		}
        }
}

客户端调用代码：

import java.net.Socket
class Test {
	static main(args) {
		def sw = new StringWriter()
		def xml = new groovy.xml.MarkupBuilder(sw)
		xml.langs(type:"current", count:3, mainstream:true){
		  language(flavor:"static", version:"1.5", "Java")
		  language(flavor:"dynamic", version:"1.6.0", "Groovy")
		  language(flavor:"dynamic", version:"1.9", "JavaScript")
		  language(flavor:"测试", version:"2.2", "闲得蛋疼")
		}
		def s = new Socket("10.14.131.114", 6666);
		s.withStreams { input, output ->
			output << sw.toString()
			byte[] msgBody = new byte[2000];
			input.read(msgBody, 0, 2000);
			def msg = new String(msgBody, 'UTF8').trim()
			println "${msg.trim()}"
		}
	}
}