Dht.go

package DhtCrawler

import (
	"fmt"
	"io"
	"log"
)

type DhtNode struct {
	node    *KNode
	table   *KTable
	network *Network
	log     *log.Logger
	master  chan string
	krpc    *KRPC
	outChan chan string
}

func NewDhtNode(id *Id, logger io.Writer, outHashIdChan chan string, master chan string) *DhtNode {
	node := new(KNode)
	node.Id = *id

	dht := new(DhtNode)
	dht.outChan = outHashIdChan
	dht.log = log.New(logger, "", log.Ldate|log.Ltime|log.Lmicroseconds|log.Lshortfile)
	dht.node = node
	dht.table = new(KTable)
	dht.network = NewNetwork(dht)
	dht.krpc = NewKRPC(dht)
	dht.master = master

	return dht
}

func (dht *DhtNode) Run() {

	//当前DHT节点运转进程
	go func() { dht.network.Listening() }()

	//自动结交更多DHT节点进程进程
	go func() { dht.NodeFinder() }()

	dht.log.Println(fmt.Sprintf("DhtCrawler %s is runing...", dht.network.Conn.LocalAddr().String()))

	for {
		select {
		case msg := <-dht.master:
			dht.log.Println(msg)
		}
	}
}