func WordJsonFile()error{ //WordTmp = getFileTmpName(WordBucket) //f,err := os.OpenFile(config.Conf.CollWordName,os.O_APPEND|os.O_CREATE|os.O_RDWR,0777) //if err != nil { // return err //} //defer f.Close() var wordUp []string defer func(){ WXDBChan<-wordUp }() return EachDB(DbWord,WordBucket,[]byte{0},func(b *bolt.Bucket,k,v []byte)error{ le := len(v) lev := le/8 if lev>50 { return nil } nolist := make([]string,0,lev) for i:=0;i<le;i+=8 { pid := v[i:i+8] nolist = append(nolist,fmt.Sprintf("\"%d\"",binary.BigEndian.Uint64(pid))) } if !bytes.HasPrefix(k,[]byte("vod")){ } _,err = f.WriteString(fmt.Sprintf("{_id:\"%s\",link:[%s]}",string(k),strings.Join(nolist,","))) return err }) }.

WordTmp stringpageTmp string.

pageVodBucket = []byte("pageVod").

WXDBPushChan = make(chan *UpdateId,100)WXDBDeleteChan = make(chan *DelId,100).

type UpdateId struct{ id uint64 ids []string}.