摸鱼派 Golang 聊天室分布式客户端

Golang-fishpi-chatroom-Distributed-client

此项目已重构

详情请查看鱼排 Go 终端客户端 - 摸鱼派 (fishpi.cn)


Gayhub地址:

摸鱼派 Golang 聊天室分布式客户端

golang第三方库

https://github.com/gorilla/websocket


更新日志

2022/1/14 更新了红包机器人 可以自动抢红包,提高抢心跳红包的概率

2022/1/16 更新了定时发消息功能

2022/1/20 更新了发红包,当前活跃度,查看历史发送消息记录,查看定时说话列表功能


目前功能

  • 接发消息
  • 红包机器人
  • 定时发消息
  • 发红包
  • 查看用户历史消息
  • 查看活跃度
  • 查看定时说话内容列表

因为上班摸鱼学的golang,边学边写的,所以暂时仅支持这些功能😋 )

创作理念(其实就是突发奇想)

一天布某人在认真(摸鱼)上班工作的时候,看着电脑面前的甲方服务器终端,发呆----

突然有一种想法,“可恶啊!我好想摸鱼!好想在摸鱼派的聊天室里水活跃度啊!!!”

可是布某人左右逢敌,左边是甲方爸爸,右边是顶头上司

布某人怎敢冒着巨大风险打开浏览器盯着摸鱼派的聊天室呢?

这时布某人灵光一闪!!“我来写一个又隐蔽又轻松又能在终端里接发消息的客户端吧!”

他这样想到。


条件-> 轻松又隐蔽

既然要隐蔽那就不能在甲方服务器上安装和创建任何东西了

不然因为摸鱼丢了工作这就得不偿失了嘛😋

解决办法:

直接使用服务器上的环境,摸鱼派聊天室的api数据从我的机器上面拿,服务器只接收临时数据

条件-> 轻松又隐蔽 解决~

分布式客户端诞生

Golang-fishpi-chatroom-Distributed-client缩写GDC

用Golang写了一个websocket的客户端,然后再用socket起一个服务端并且把从摸鱼派聊天室接收到的json数据进行处理然后分发给对GDC进行tcp连接的客户端

重点TCP客户端,只要是能进行tcp连接的客户端就可以进行接发消息

获取用户apiKey格式

-nameOrEmail&&passwd

可以多用户在线,放内网里,开启一个服务多人连接一起嗨皮,一起摸鱼

也可以放公网vps,自建服务器上,但是目前暂不支持消息加密服务,所以不建议放公网上

红包机器人演示:

已经被领取就run~

image.png

抢到的红包~

image.png


tcp客户端例子

python的tcp客户端

#!/bin/python3
# -*- coding:utf-8 -*-
import socket
import threading
import sys

address = sys.argv[1]  # 服务端地址
port = int(sys.argv[2])  # 端口


def link():
    sc = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    sc.connect((address, port))
    threading.Thread(target=send, args=(sc, )).start()
    while True:
        try:
            a = sc.recv(1024)
            print(a.decode("utf-8"))
        except KeyboardInterrupt:  # ctrl c退出
            sc.close()
            return


def send(sc):
    while True:
        msg = input(">>")
        sc.sendall(msg.encode())


c = threading.Thread(target=link())
c.setDaemon(True)
c.start()

image.png

Golang的tcp客户端

package main

import (
	"bufio"
	"flag"
	"fmt"
	"log"
	"net"
	"os"
	"strings"
)

var ip string
var port string

func init() {
	flag.StringVar(&ip, "i", "", "服务ip地址")
	flag.StringVar(&port, "p", "33333", "服务端口,默认33333")
}

func input(conn net.Conn) {
	for {
		var buf [1024]byte
		read := bufio.NewReader(os.Stdin)
		m, err := read.Read(buf[:])
		if err != nil {
			log.Println("Login out")
			return
		}
		recv := strings.Split(string(buf[:m]), "\n")[0]
		conn.Write([]byte(recv))
	}
}

func main() {
	flag.Parse()
	host := fmt.Sprintf("%s:%s", ip, port)
	conn, err := net.Dial("tcp", host)
	if err != nil {
		log.Panicln("connect fail", err)
		return
	}
	defer conn.Close()
	go input(conn)
	for {
		var buf [1024]byte
		read := bufio.NewReader(conn)
		n, err := read.Read(buf[:])
		if err != nil {
			fmt.Println("recv failed, err:", err)
			return
		}
		fmt.Println(string(buf[:n]))
	}
}

image.png

甚至是netcat

image.png

服务端

![image.png](image.png