無法創建連接到Cassandra的會話

我想讓這個例子工作。

func main() { 
    // connect to the cluster 
    cluster := gocql.NewCluster("192.168.1.1", "192.168.1.2", "192.168.1.3") 
    cluster.ProtoVersion = 3 
    cluster.Keyspace = "example" 
    cluster.Consistency = gocql.Quorum 
    session, err := cluster.CreateSession() 
    defer session.Close() 
    if err != nil { 
     fmt.Printf("%v\n", err) 
     return 
    } 

    uuid := gocql.TimeUUID() 
    fmt.Printf("UUID : %v", uuid) 

    query := session.Query(`INSERT INTO tweet (timeline, id, text) VALUES   
    (?, ?, ?)`, "me", uuid, "hello world") 

    fmt.Println("About to exec") 
    err = query.Exec() 

    // insert a tweet 
    if err != nil { 
     log.Fatal(err) 
    } 

    var id gocql.UUID 
    var text string 

    /* Search for a specific set of records whose 'timeline' column matches 
    * the value 'me'. The secondary index that we created earlier will be 
    * used for optimizing the search */ 
    if err := session.Query(`SELECT id, text FROM tweet WHERE timeline = ?  
    LIMIT 1`,"me").Consistency(gocql.One).Scan(&id, &text); err != nil { 
     log.Fatal(err) 
    } 
    fmt.Println("Tweet:", id, text) 

    // list all tweets 
    iter := session.Query(`SELECT id, text FROM tweet WHERE timeline = ?`, 
    "me").Iter() 
    for iter.Scan(&id, &text) { 
     fmt.Println("Tweet:", id, text) 
    } 
    if err := iter.Close(); err != nil { 
     log.Fatal(err) 
    } 
}

使用Cassandra的殼我已經創建密鑰空間「榜樣」和表「鳴叫」，他們都做工精細。

然而，當我運行程序，它給了我這個錯誤：

2017/04/14 20:52:55 gocql: unable to dial control conn 192.168.1.3: dial tcp  
192.168.1.3:9042: i/o timeout 
gocql: unable to create session: control: unable to connect to initial 
hosts: dial tcp 192.168.1.3:9042: i/o timeoutpanic: runtime error: invalid 
memory address or nil pointer dereference 
[signal 0xc0000005 code=0x0 addr=0x0 pc=0x60236d] 

goroutine 1 [running]: 
github.com/gocql/gocql.(*Session).Close(0x0) 
    /home/mda/.local/go/src/github.com/gocql/gocql/session.go:344 +0x2d

出於某種原因，gocql無法撥打本地主機連接，並且超時。我不知道如何解決這個問題，一個stackoverflow和谷歌搜索迄今沒有幫助。

任何想法？

來源

2017-04-15 SomeGuyFortune

可以提供notedool狀態和cassandra.yaml文件從一個節點？我根本不會真的改變協議版本。 –

我不完全確定要尋找什麼。但是當我在命令promt上鍵入「nodetool status」時，這就是我得到的。 **數據中心：數據中心1 ======================== 狀態=上/下 |/State = Normal/Leaving/Joining/Moving - - 地址負載令牌擁有者（有效）主機ID機架 UN 127.0.0.1 182.43 KB 256 100.0％###某些主機ID機架1 ** – SomeGuyFortune

cassandra.yaml文件較大。特別是你想從cassandra.yaml文件中獲得什麼信息？如果有幫助，我沒有改變任何東西。這就像當我下載cassandra – SomeGuyFortune

看起來像IP地址不是根據您的計算機上的羣集情況。在給我nodetool狀態後，我認爲你應該更新cluster := gocql.NewCluster只有127.0.0.1地址，而不是例子中的地址。

我想在現實中你只是運行單個節點cassandra本地實例。這對開發很好。

基本上是：

cluster := gocql.NewCluster("127.0.0.1")

和剛落，該行的所有一起

cluster.ProtoVersion = 3

來源

2017-04-15 05:09:58

我最初將協議設置爲4.並且它仍然產生相同的錯誤消息。 – SomeGuyFortune

無法創建連接到Cassandra的會話

回答

相關問題