chat.go

package main

import "fmt"
import "redis"
import "bytes"
import "os"

func main() {
	var input string
	fmt.Print("What game server chat u want in on: ")
	fmt.Scanln(&input)
	var channelKey string = "games:"+input+":chat"
	//msg := connectClient(channelKey)
	go connectClient(channelKey)
	go spamChat1(channelKey)
	//chatbuf := bytes.NewBuffer(<-msg)
	//chatbuf.WriteTo(os.Stdout)
	fmt.Scanln(&input)
		
}

func connectClient(chanKey string) {
	
	//mc := make(chan []byte)
	spec := redis.DefaultSpec().Password("go-redis")
	client, e := redis.NewPubSubClientWithSpec(spec)
	if e != nil {
		fmt.Print("Error creating client for: ", e)
	}
	defer client.Quit()
	fmt.Println("before subbing")
	client.Subscribe("chat")
	fmt.Println("after subbing")
	//return client.Messages("chat")
	//fmt.Println(string(<-client.Messages("chat")))
	//fmt.Println(string(<-client.Messages("chat")))
	go func() {
		for {
			//mc <-client.Messages("chat");	
			chatbuf := bytes.NewBuffer(<-client.Messages("chat"))
			chatbuf.WriteTo(os.Stdout)
		}
	}()
}

func spamChat1(chanKey string) {
	fmt.Println("spamchat being called") 
	spec := redis.DefaultSpec().Password("go-redis")
	client, e := redis.NewAsynchClientWithSpec(spec)
	if e != nil {
		fmt.Print("Error creating spam client for: ", e)
	}
	defer client.Quit()
	
	for i:=0; i<1000000; i++ {
		var fr redis.FutureInt64
		//var fr2 redis.FutureBool
		var buf bytes.Buffer
		buf.Write([]byte("hello"+string(i)))
		bt := buf.Bytes() 
		fr, e = client.Publish("chat", bt)
		//fmt.Println("we got past 2 publishes")
		if e != nil {
			fmt.Println("error in publishing: ", e)
		}
		_, e = client.Rpush("chatlog",bt)
		if e != nil {
			fmt.Println("error in storing list: ", e)
		}
		
		numRecieved,_ := fr.Get()
		//fmt.Println(numRecieved)
		//fr2.Get()
	}
}