• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

Go语言中的UDP应用

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

Go语言中使用UDP是很方便的,net包提供了UDP和TCP的功能,这里使用UDP做了一个UDP广播,然后接收各个设备的返回信息。实现起来很快,总体感觉比使用C#中的UDP更优雅,简洁。

package main

import (
	"fmt"
	"net"
	"time"
	"strings"
	"reflect"
)

func recvUDPMsg(conn *net.UDPConn){
	fmt.Println("进入了")
	for{
		var buf [1024] byte
		n, raddr, err := conn.ReadFromUDP(buf[0:])
		if err != nil{
			fmt.Println(err)
			return
		}
		content := string(buf[0:n])
		hmis := strings.Split(content, ",")
		hmi := new(HMIModel)
		hmi.ReflectInfo(hmis)
		fmt.Println(hmi)
		
		_, err = conn.WriteToUDP([]byte("hello world"), raddr)
		if err != nil {
			fmt.Println(err)
		}
	}

}
type HMIModel struct{
	company string
	ip string
	hostname string
	pncode string
	versoft string
	projectname string
}
func (this HMIModel) ReflectInfo(hmis []string){
	f := reflect.TypeOf(this)	
	v := reflect.ValueOf(this)
	for i := 0; i < f.NumField(); i++{
		for j := 0; j < len(hmis); j++{
			contents := strings.Split(hmis[i], "=")
			if contents[0] == f.Field(i).Name{
				v.Field(i).SetString(contents[1])
				break
			}

		}
	}
}

func main(){
	fmt.Println("开始了")
	udp_addr, err := net.ResolveUDPAddr("udp", "192.168.200.221:1100")
	if err != nil{
		fmt.Println(err)
		return
	}
	conn, err := net.ListenUDP("udp", udp_addr)
	if err != nil {
		fmt.Println(err)
		return
	}

	go recvUDPMsg(conn)
	raddr := net.UDPAddr{
		IP: net.ParseIP("255.255.255.255"),
		Port: 3366,
	}
	for{
		conn.WriteToUDP([]byte("hello world"), &raddr)

		time.Sleep(3 * time.Second)
	}
}

鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
GOChannel并发、死锁问题发布时间:2022-07-10
下一篇:
Go语言基础之结构体发布时间:2022-07-10
热门推荐
热门话题
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap