加入收藏 | 设为首页 | 会员中心 | 我要投稿 李大同 (https://www.lidatong.com.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 大数据 > 正文

GO语言UDP小笔记

发布时间:2020-12-16 18:40:27 所属栏目:大数据 来源:网络整理
导读:package mainimport ("bytes""encoding/json""fmt""io""net""os")type Fileinfo struct {Name stringPath string}func server() {laddr := net.UDPAddr{IP: []byte{127,1},Port: 1789}con,err := net.ListenUDP("udp",laddr)if err != nil {fmt.Println(err)
package main

import (
	"bytes"
	"encoding/json"
	"fmt"
	"io"
	"net"
	"os"
)

type Fileinfo struct {
	Name string
	Path string
}

func server() {
	laddr := &net.UDPAddr{IP: []byte{127,1},Port: 1789}
	con,err := net.ListenUDP("udp",laddr)
	if err != nil {
		fmt.Println(err)
		return
	}
	defer con.Close()
	for {
		Buf := make([]byte,1024)
		n,raddr,_ := con.ReadFromUDP(Buf)
		var info Fileinfo
		json.Unmarshal(Buf[:n],&info)
		if info.Name != "" {
			if info.Path != "" {
				e := os.Chdir(info.Path)
				if e != nil {
					con.WriteTo([]byte(e.Error()),raddr)
					continue
				}
			}
			con.WriteToUDP([]byte("OK"),raddr)
			File,_ := os.Create(info.Name)
			defer File.Close()
			for {
				Buf := make([]byte,4096)
				n,r,_ := con.ReadFromUDP(Buf)
				if r.String() != raddr.String() {
					continue
				}
				if n == 4 && bytes.Contains([]byte{0,69,79,70},Buf[:n]) {
					File.Sync()
					File.Close()
					break
				}
				File.Write(Buf[:n])
			}
		}
	}
}

func client() {
	con,e := net.Dial("udp","127.0.0.1:1789")
	if e != nil {
		fmt.Println(e)
		return
	}
	defer con.Close()
	var info Fileinfo = Fileinfo{Name: "WinMD5.exe",Path: "D:"}
	b,_ := json.Marshal(info)
	con.Write([]byte(b))
	Buf := make([]byte,1024)
	n,_ := con.Read(Buf)
	if string(Buf[:n]) == "OK" {
		File,_ := os.Open("3.go")
		for {
			Buf := make([]byte,4096)
			n,e := File.Read(Buf)
			if e != nil {
				if e == io.EOF {
					break
				}
				fmt.Println(e)
				break
			}
			con.Write(Buf[:n])
		}
		con.Write([]byte{0,70})
	}
}

(编辑:李大同)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读