组织名改为changba-server -> changba

LICENSE

@@ -1,6 +1,6 @@
 MIT License
 
-Copyright (c) 2020 changba-server
+Copyright (c) 2020 changba
 
 Permission is hereby granted, free of charge, to any person obtaining a copy
 of this software and associated documentation files (the "Software"), to deal

README.md

@@ -1,10 +1,10 @@
 # NSQ Proxy
 NSQ Proxy是Golang开发的NSQ和Worker之间的中间件，根据数据库配置，负责消息转发。NSQProxy启动后，接受NSQD队列内容，然后通过HTTP/FastCGI/CBNSQ等协议转发给Worker机执行。在唱吧内部使用2年，高效稳定的处理着每日数十亿条消息。
 
-[![go report card](https://goreportcard.com/badge/github.com/changba-server/nsqproxy "go report card")](https://goreportcard.com/report/github.com/changba-server/nsqproxy)
-[![MIT license](https://img.shields.io/badge/license-MIT-brightgreen.svg)](https://github.com/changba-server/nsqproxy/blob/master/LICENSE)
-[![Downloads](https://img.shields.io/github/downloads/changba-server/nsqproxy/total.svg)](https://github.com/changba-server/nsqproxy/releases)
-[![Release](https://img.shields.io/github/release/changba-server/nsqproxy.svg?label=Release)](https://github.com/changba-server/nsqproxy/releases)
+[![go report card](https://goreportcard.com/badge/github.com/changba/nsqproxy "go report card")](https://goreportcard.com/report/github.com/changba/nsqproxy)
+[![MIT license](https://img.shields.io/badge/license-MIT-brightgreen.svg)](https://github.com/changba/nsqproxy/blob/master/LICENSE)
+[![Downloads](https://img.shields.io/github/downloads/changba/nsqproxy/total.svg)](https://github.com/changba/nsqproxy/releases)
+[![Release](https://img.shields.io/github/release/changba/nsqproxy.svg?label=Release)](https://github.com/changba/nsqproxy/releases)
 
 ## 解决的问题
 
@@ -41,7 +41,7 @@ NSQ Proxy是Golang开发的NSQ和Worker之间的中间件，根据数据库配
 
 #### 二进制安装
 
-* 下载最新版本的压缩包 https://github.com/changba-server/nsqproxy/releases
+* 下载最新版本的压缩包 https://github.com/changba/nsqproxy/releases
 * 解压
 * 启动（注意替换为自己的MySQL信息） `./nsqproxy -dbHost=127.0.0.1 -dbPort=3306 -dbUsername=root -dbPassword=rootpsd -dbName=nsqproxy -logLevel=debug -nsqlookupdHTTP=127.0.0.1:4161`
 * 命令行 `curl http://0.0.0.0:19421/status` 输出ok
@@ -50,7 +50,7 @@ NSQ Proxy是Golang开发的NSQ和Worker之间的中间件，根据数据库配
 #### 源码安装
 
 * 要求Go1.13及以上
-* 下载本项目 `go get github.com/changba-server/nsqproxy`
+* 下载本项目 `go get github.com/changba/nsqproxy`
 * `cd nsqproxy`
 * `export GO111MODULE=on`
 * 编译 `make build`
@@ -94,4 +94,4 @@ NSQ Proxy是Golang开发的NSQ和Worker之间的中间件，根据数据库配
 
 © [Changba.com](https://changba.com), 2020~time.Now
 
-Released under the [MIT License](https://github.com/changba-server/nsqproxy/blob/main/LICENSE)
+Released under the [MIT License](https://github.com/changba/nsqproxy/blob/main/LICENSE)

cmd/nsqproxy.go

@@ -4,13 +4,13 @@ package main
 //go:generate statik -src=../web/public/ -dest=../internal -f
 
 import (
-	"github.com/changba-server/nsqproxy/config"
-	"github.com/changba-server/nsqproxy/internal/backup"
-	"github.com/changba-server/nsqproxy/internal/httper"
-	"github.com/changba-server/nsqproxy/internal/model"
-	"github.com/changba-server/nsqproxy/internal/module/logger"
-	"github.com/changba-server/nsqproxy/internal/module/tool"
-	"github.com/changba-server/nsqproxy/internal/proxy"
+	"github.com/changba/nsqproxy/config"
+	"github.com/changba/nsqproxy/internal/backup"
+	"github.com/changba/nsqproxy/internal/httper"
+	"github.com/changba/nsqproxy/internal/model"
+	"github.com/changba/nsqproxy/internal/module/logger"
+	"github.com/changba/nsqproxy/internal/module/tool"
+	"github.com/changba/nsqproxy/internal/proxy"
 	"os"
 	"os/signal"
 	"syscall"

config/systemconfig.go

@@ -2,8 +2,8 @@ package config
 
 import (
 	"flag"
-	"github.com/changba-server/nsqproxy/internal/module/logger"
-	"github.com/changba-server/nsqproxy/internal/module/tool"
+	"github.com/changba/nsqproxy/internal/module/logger"
+	"github.com/changba/nsqproxy/internal/module/tool"
 	"strings"
 	"time"
 )

document/doc/quick_start.md

@@ -28,7 +28,7 @@ MySQL中存储着各Topic/Channel的配置信息，因此NSQProxy依赖于MySQL
 ## 下载安装
 下载并启动NSQProxy。
 
-* 下载最新版本的压缩包 https://github.com/changba-server/nsqproxy/releases
+* 下载最新版本的压缩包 https://github.com/changba/nsqproxy/releases
 * 解压
 * 启动（注意替换为自己的MySQL信息） `./nsqproxy -dbHost=127.0.0.1 -dbPort=3306 -dbUsername=root -dbPassword=rootpsd -dbName=nsqproxy -logLevel=debug -nsqlookupdHTTP=127.0.0.1:4161`
 * 命令行 `curl http://0.0.0.0:19421/status` 输出ok
@@ -84,4 +84,4 @@ func main() {
 
 2、查看刚才编写的Golang程序的输出，可以拿到消息的唯一ID和消息的内容
 
-<img src="https://raw.githubusercontent.com/changba-server/nsqproxy/main/assets/images/quick_start_demo.png" alt="具体示例">
+<img src="https://raw.githubusercontent.com/changba/nsqproxy/main/assets/images/quick_start_demo.png" alt="具体示例">

go.mod

@@ -1,4 +1,4 @@
-module github.com/changba-server/nsqproxy
+module github.com/changba/nsqproxy
 
 go 1.14
 

internal/backup/live.go

@@ -2,7 +2,7 @@ package backup
 
 import (
 	"encoding/json"
-	"github.com/changba-server/nsqproxy/internal/module/logger"
+	"github.com/changba/nsqproxy/internal/module/logger"
 	"io/ioutil"
 	"net/http"
 	"time"

internal/httper/consumeconfig.go

@@ -1,7 +1,7 @@
 package httper
 
 import (
-	"github.com/changba-server/nsqproxy/internal/model"
+	"github.com/changba/nsqproxy/internal/model"
 	"net/http"
 	"strconv"
 	"time"

internal/httper/consumeservermap.go

@@ -1,7 +1,7 @@
 package httper
 
 import (
-	"github.com/changba-server/nsqproxy/internal/model"
+	"github.com/changba/nsqproxy/internal/model"
 	"net/http"
 	"strconv"
 	"strings"

internal/httper/http.go

@@ -1,7 +1,7 @@
 package httper
 
 import (
-	_ "github.com/changba-server/nsqproxy/internal/statik"
+	_ "github.com/changba/nsqproxy/internal/statik"
 	"github.com/rakyll/statik/fs"
 	"net/http"
 	_ "net/http/pprof"

internal/httper/response.go

@@ -2,7 +2,7 @@ package httper
 
 import (
 	"encoding/json"
-	"github.com/changba-server/nsqproxy/internal/module/logger"
+	"github.com/changba/nsqproxy/internal/module/logger"
 	"net/http"
 )
 

internal/httper/router.go

@@ -1,7 +1,7 @@
 package httper
 
 import (
-	"github.com/changba-server/nsqproxy/config"
+	"github.com/changba/nsqproxy/config"
 	"net/http"
 )
 

internal/httper/workserver.go

@@ -1,7 +1,7 @@
 package httper
 
 import (
-	"github.com/changba-server/nsqproxy/internal/model"
+	"github.com/changba/nsqproxy/internal/model"
 	"net/http"
 	"strconv"
 )

internal/module/tool/error.go

@@ -1,7 +1,7 @@
 package tool
 
 import (
-	"github.com/changba-server/nsqproxy/internal/module/logger"
+	"github.com/changba/nsqproxy/internal/module/logger"
 	"runtime/debug"
 )
 

internal/proxy/handle.go

@@ -2,10 +2,10 @@ package proxy
 
 import (
 	"errors"
-	"github.com/changba-server/nsqproxy/config"
-	"github.com/changba-server/nsqproxy/internal/model"
-	"github.com/changba-server/nsqproxy/internal/module/logger"
-	"github.com/changba-server/nsqproxy/internal/worker"
+	"github.com/changba/nsqproxy/config"
+	"github.com/changba/nsqproxy/internal/model"
+	"github.com/changba/nsqproxy/internal/module/logger"
+	"github.com/changba/nsqproxy/internal/worker"
 	"github.com/nsqio/go-nsq"
 	"strconv"
 )

internal/proxy/handle_test.go

@@ -1,7 +1,7 @@
 package proxy
 
 import (
-	"github.com/changba-server/nsqproxy/internal/model"
+	"github.com/changba/nsqproxy/internal/model"
 	"testing"
 )
 

internal/proxy/loadbalance.go

@@ -2,7 +2,7 @@ package proxy
 
 import (
 	"errors"
-	"github.com/changba-server/nsqproxy/internal/model"
+	"github.com/changba/nsqproxy/internal/model"
 )
 
 const LoadBalanceMethodLoop = "loop"

internal/proxy/loadbalance_test.go

@@ -1,7 +1,7 @@
 package proxy
 
 import (
-	"github.com/changba-server/nsqproxy/internal/model"
+	"github.com/changba/nsqproxy/internal/model"
 	"testing"
 )
 

internal/proxy/proxy.go

@@ -3,10 +3,10 @@ package proxy
 import (
 	"errors"
 	"fmt"
-	"github.com/changba-server/nsqproxy/config"
-	"github.com/changba-server/nsqproxy/internal/model"
-	"github.com/changba-server/nsqproxy/internal/module/logger"
-	"github.com/changba-server/nsqproxy/internal/module/tool"
+	"github.com/changba/nsqproxy/config"
+	"github.com/changba/nsqproxy/internal/model"
+	"github.com/changba/nsqproxy/internal/module/logger"
+	"github.com/changba/nsqproxy/internal/module/tool"
 	"github.com/nsqio/go-nsq"
 	"strconv"
 	"time"

internal/proxy/proxy_test.go

@@ -1,8 +1,8 @@
 package proxy
 
 import (
-	"github.com/changba-server/nsqproxy/config"
-	"github.com/changba-server/nsqproxy/internal/model"
+	"github.com/changba/nsqproxy/config"
+	"github.com/changba/nsqproxy/internal/model"
 	"testing"
 	"time"
 )

internal/worker/fastcgi.go

@@ -2,8 +2,8 @@ package worker
 
 import (
 	"bytes"
-	"github.com/changba-server/nsqproxy/config"
-	"github.com/changba-server/nsqproxy/internal/module/fastcgi"
+	"github.com/changba/nsqproxy/config"
+	"github.com/changba/nsqproxy/internal/module/fastcgi"
 	"github.com/nsqio/go-nsq"
 	"io/ioutil"
 )

internal/worker/http.go

@@ -2,7 +2,7 @@ package worker
 
 import (
 	"errors"
-	"github.com/changba-server/nsqproxy/internal/module/tool"
+	"github.com/changba/nsqproxy/internal/module/tool"
 	"github.com/nsqio/go-nsq"
 	"io/ioutil"
 	"net/http"