Hivechat：去中心化社交协议的下一代MPC服务端深度测评

# 1. 安装Docker Desktop
# 下载地址：https://www.docker.com/products/docker-desktop/

# 2. 克隆Hivechat仓库
git clone https://github.com/hivechat/hivechat-server.git
cd hivechat-server

# 3. 创建配置文件
copy config.sample.yaml config.yaml

# 4. 修改配置文件（主要配置项）
nano config.yaml

server_name: "your-domain.com"
listen_port: 8008
database:
  type: "postgres"
  connection_string: "postgresql://user:password@localhost/hivechat"

# 5. 使用Docker Compose启动服务
docker-compose up -d

# 6. 验证安装
curl http://localhost:8008/_matrix/client/versions

# 解决方案：修改监听端口
docker-compose down
# 编辑docker-compose.yml，修改端口映射
# 重新启动
docker-compose up -d

# 检查PostgreSQL服务状态
docker ps | grep postgres
# 重新初始化数据库
docker-compose exec app python manage.py init_db

# 1. 安装Homebrew
/bin/bash -c "$(curl -fsSL https://raw.githubusercontent.com/Homebrew/install/HEAD/install.sh)"

# 2. 安装Docker Desktop
brew install --cask docker

# 3. 安装依赖工具
brew install postgresql redis

# 4. 克隆并配置项目
git clone https://github.com/hivechat/hivechat-server.git
cd hivechat-server

# 5. 启动服务
make dev-env
make run

# 1. 更新系统包
sudo apt update && sudo apt upgrade -y

# 2. 安装Docker和Docker Compose
curl -fsSL https://get.docker.com -o get-docker.sh
sudo sh get-docker.sh
sudo usermod -aG docker $USER

# 3. 安装Git
sudo apt install git -y

# 4. 部署Hivechat
git clone https://github.com/hivechat/hivechat-server.git
cd hivechat-server

# 5. 配置环境变量
cp .env.example .env
nano .env

# 6. 启动服务
docker-compose up -d

# 7. 检查服务状态
docker-compose logs -f

#!/usr/bin/env python3
"""
Hivechat管理工具 - 企业内部通信系统初始化
"""

import requests
import json
import logging

class HivechatManager:
    def __init__(self, base_url, admin_token):
        self.base_url = base_url
        self.headers = {
            'Authorization': f'Bearer {admin_token}',
            'Content-Type': 'application/json'
        }
    
    def create_user(self, username, password, display_name):
        """创建用户"""
        url = f"{self.base_url}/_synapse/admin/v2/users/@{username}:{self.base_url.split('//')[1]}"
        
        data = {
            "password": password,
            "displayname": display_name,
            "admin": False
        }
        
        response = requests.put(url, headers=self.headers, json=data)
        return response.json()
    
    def create_room(self, room_name, topic, users=None):
        """创建聊天房间"""
        url = f"{self.base_url}/_matrix/client/r0/createRoom"
        
        data = {
            "name": room_name,
            "topic": topic,
            "preset": "private_chat",
            "invite": users or []
        }
        
        response = requests.post(url, headers=self.headers, json=data)
        return response.json()
    
    def send_message(self, room_id, message):
        """发送消息"""
        url = f"{self.base_url}/_matrix/client/r0/rooms/{room_id}/send/m.room.message"
        
        data = {
            "msgtype": "m.text",
            "body": message
        }
        
        response = requests.post(url, headers=self.headers, json=data)
        return response.json()

# 使用示例
if __name__ == "__main__":
    # 初始化管理器
    manager = HivechatManager(
        base_url="http://localhost:8008",
        admin_token="your_admin_access_token"
    )
    
    # 创建部门用户
    departments = {
        "tech": ["alice", "bob", "charlie"],
        "marketing": ["david", "eve", "frank"],
        "hr": ["grace", "henry", "ivy"]
    }
    
    # 批量创建用户
    for dept, users in departments.items():
        for user in users:
            result = manager.create_user(
                username=f"{user}_{dept}",
                password="secure_password_123",
                display_name=f"{user.title()} ({dept.upper()})"
            )
            print(f"Created user: {user}_{dept}")
    
    # 创建部门群组
    tech_room = manager.create_room(
        room_name="技术部工作群",
        topic="技术讨论和代码评审",
        users=[f"@{user}_tech:localhost" for user in departments["tech"]]
    )
    
    print(f"Created tech room: {tech_room['room_id']}")
    
    # 发送欢迎消息
    manager.send_message(
        room_id=tech_room['room_id'],
        message="欢迎加入技术部工作群！请遵守公司通信规范。"
    )

#!/bin/bash
# hivechat-auto-deploy.sh

set -e

echo "开始部署Hivechat企业内部通信系统..."

# 检查Docker是否安装
if ! command -v docker &> /dev/null; then
    echo "安装Docker..."
    curl -fsSL https://get.docker.com -o get-docker.sh
    sh get-docker.sh
fi

# 创建项目目录
mkdir -p /opt/hivechat-enterprise
cd /opt/hivechat-enterprise

# 下载配置文件
wget https://raw.githubusercontent.com/hivechat/hivechat-server/main/docker-compose.prod.yml
wget https://raw.githubusercontent.com/hivechat/hivechat-server/main/config.prod.yaml

# 创建环境文件
cat > .env << EOF
SERVER_NAME=company-internal.com
POSTGRES_PASSWORD=$(openssl rand -base64 32)
REDIS_PASSWORD=$(openssl rand -base64 32)
JWT_SECRET=$(openssl rand -base64 64)
EOF

# 启动服务
docker-compose -f docker-compose.prod.yml up -d

echo "等待服务启动..."
sleep 30

# 验证部署
if curl -f http://localhost:8008/_matrix/client/versions; then
    echo "✅ Hivechat部署成功！"
    echo "管理地址: http://localhost:8008"
    echo "客户端连接地址: company-internal.com:8008"
else
    echo "❌ 部署失败，请检查日志"
    docker-compose logs
fi

#!/usr/bin/env python3
"""
Hivechat系统监控工具
"""

import requests
import time
import smtplib
from email.mime.text import MimeText

class HivechatMonitor:
    def __init__(self, server_url, alert_email=None):
        self.server_url = server_url
        self.alert_email = alert_email
    
    def check_health(self):
        """检查服务健康状态"""
        checks = {
            "server_online": self._check_server_online(),
            "database_connection": self._check_database(),
            "message_delivery": self._check_message_flow()
        }
        
        return checks
    
    def _check_server_online(self):
        try:
            response = requests.get(f"{self.server_url}/_matrix/client/versions", timeout=10)
            return response.status_code == 200
        except:
            return False
    
    def _check_database(self):
        try:
            response = requests.get(f"{self.server_url}/_synapse/admin/v1/server_version", timeout=10)
            return response.status_code == 200
        except:
            return False
    
    def _check_message_flow(self):
        # 模拟消息发送测试
        try:
            test_data = {
                "msgtype": "m.text",
                "body": "健康检查测试消息"
            }
            response = requests.post(
                f"{self.server_url}/_matrix/client/r0/rooms/!test:localhost/send/m.room.message",
                json=test_data,
                timeout=10
            )
            return response.status_code in [200, 403]  # 403表示权限问题，但服务正常
        except:
            return False
    
    def send_alert(self, message):
        """发送告警邮件"""
        if self.alert_email:
            # 实现邮件发送逻辑
            msg = MimeText(message)
            msg['Subject'] = 'Hivechat系统告警'
            msg['From'] = 'monitor@company.com'
            msg['To'] = self.alert_email
            
            # 使用SMTP发送邮件
            # smtp.send_message(msg)
            print(f"发送告警: {message}")

# 使用监控系统
monitor = HivechatMonitor(
    server_url="http://localhost:8008",
    alert_email="admin@company.com"
)

while True:
    health = monitor.check_health()
    
    if not all(health.values()):
        failed_services = [k for k, v in health.items() if not v]
        alert_msg = f"服务异常: {', '.join(failed_services)}"
        monitor.send_alert(alert_msg)
    
    time.sleep(300)  # 每5分钟检查一次