The persistent storage data restart project disappears

[qweawdqq]

The persistent storage data restart project disappears

[qweawdqq]

刚添加完的索引是能够查询到的，但是重启工程之后，就查询不到之前添加的索引了

[vcaesar]

Please provide the code.

[qweawdqq]

//标题、作者、标签
func AddContent(title,content,author string,labels[]string)(err error)  {
    //defer searcher.Close()
    //错误
    log.Println("添加了文件标题为: ", title)

    //err = GetError()
    //为文件添加属性
    attri :=types.Attri{title,author,unit.GetTimeNow(),0}
    ct :=types.DocData{Content: content}
    ct.Attri=attri
    //如果类别不为空则添加类别
    if labels != nil || len(labels) >0{
        ct.Labels = labels
    }
    //生成主键
    docid := uint64(time.Now().Unix())
    //插入
    searcher.Index(docid, ct)
    //searcher.Index(22, types.DocData{Content: content})
    //刷新
    searcher.Flush()
    log.Println("创建的索引数量: ", searcher.NumDocsIndexed())

    return err
}

[qweawdqq]

我是使用了一个web框架（beego）,请求过来之后在进行添加搜索文档的

[qweawdqq]

Take a look at the code I duplicated.Adding is good, but as long as the service is restarted, there is no data added before.

[qweawdqq]

I used a web framework (beego) After the request comes in, the search document is added. The files added before restarting the service disappeared

[vcaesar]

Please restore index first, then try gob registration,

gob.Register(MyAttriStruct{})

[qweawdqq]

Thank you very much. The problem has been solved.

[zlykernel]

Thank you very much. The problem has been solved. 能提供一下 解决的代码吗

[zlykernel]

我也遇到同样问题，go version go1.12.4 linux/amd64 代码如下： package main

import ( "log" "net/http" "time"

// rhttp "github.com/go-ego/riot/net/http"

"github.com/go-ego/riot"
"github.com/go-ego/riot/types"

)

var ( // searcher is coroutine safe searcher = riot.Engine{}

opts = types.EngineOpts{
    Using: 1,
    IndexerOpts: &types.IndexerOpts{
        IndexType: types.DocIdsIndex,
    },
    UseStore: true,
    StoreFolder: "riot-index-data",
    StoreEngine: "bg", // bg: badger, lbd: leveldb, bolt: bolt
}

)

//标题、作者、标签 func AddContent(title,content,author string,labels[]string)(err error) { //defer searcher.Close() //错误 log.Println("添加了文件标题为: ", title)

//err = GetError()
//为文件添加属性
attri :=types.Attri{title,author,time.Now().Format("2006-01-02 15:04:05"),0}
ct :=types.DocData{Content: content}
ct.Attri=attri
//如果类别不为空则添加类别
if labels != nil || len(labels) >0{
    ct.Labels = labels
}
//生成主键
docid := time.Now().Format("2006-01-02 15:04:05")
//插入
searcher.Index(docid, ct)
//刷新
searcher.Flush()
log.Println("创建的索引数量: ", searcher.NumDocsIndexed())
return err

}

func Add(w http.ResponseWriter, req *http.Request){ AddContent("title1","content1","author1",[]string{"false"}) log.Println("after Add 创建的索引数量: ", searcher.NumDocsIndexed()) // restoreIndex() }

func restoreIndex() { searcher.Init(opts) defer searcher.Close() searcher.Flush() log.Println("recover index number: ", searcher.NumDocsIndexed()) }

func main() {

searcher.Init(opts)
// restoreIndex()
log.Println("创建的索引数量: ", searcher.NumDocsIndexed())
// http.HandleFunc("/search", rhttp.Search)
// http.HandleFunc("/dist", rhttp.WgDist)
// http.HandleFunc("/Add", Add)
// log.Println("listen and serve on 8080...")
// log.Fatal(http.ListenAndServe(":8088", nil))

// Add(nil,nil)
// searcher.Flush()

sea := searcher.Search(types.SearchReq{
    Text: "content1",
    RankOpts: &types.RankOpts{
        OutputOffset: 0,
        MaxOutputs:   100,
    }})
log.Println("查询: ", sea)

defer searcher.Close()

}