Hotnews MCP Server测评：一站式中文社交平台热点追踪方案

npx @mcp/hotnews-server

# 拉取镜像
docker pull mcp/hotnews-server:latest

# 运行容器
docker run -d -p 8080:8080 --name hotnews-server mcp/hotnews-server:latest

{
  "mcpServers": {
    "hotnews": {
      "command": "docker",
      "args": ["run", "-i", "--rm", "mcp/hotnews-server"]
    }
  }
}

/**
 * 基于Hotnews MCP Server的多平台热点监控系统
 * 支持关键词过滤、热度分析和定时监控
 */

class HotNewsMonitor {
  constructor(serverUrl, options = {}) {
    this.serverUrl = serverUrl;
    this.keywords = options.keywords || [];
    this.platforms = options.platforms || ['weibo', 'zhihu', 'douyin'];
    this.checkInterval = options.interval || 300000; // 5分钟
    this.onNewHotTopic = options.onNewHotTopic || null;
    this.history = new Map();
  }

  /**
   * 启动监控
   */
  start() {
    console.log(`开始监控热点话题，检查间隔: ${this.checkInterval/1000}秒`);
    this._fetchAndProcess();
    this.timer = setInterval(() => {
      this._fetchAndProcess();
    }, this.checkInterval);
  }

  /**
   * 停止监控
   */
  stop() {
    if (this.timer) {
      clearInterval(this.timer);
      console.log('热点话题监控已停止');
    }
  }

  /**
   * 添加关键词
   */
  addKeyword(keyword) {
    if (!this.keywords.includes(keyword)) {
      this.keywords.push(keyword);
      console.log(`添加关键词: ${keyword}`);
    }
  }

  /**
   * 获取热点新闻
   */
  async _fetchHotNews() {
    try {
      // 这里是模拟的MCP客户端调用
      // 实际使用时需要根据具体的MCP客户端实现进行调整
      const response = await fetch(this.serverUrl, {
        method: 'POST',
        headers: {
          'Content-Type': 'application/json',
        },
        body: JSON.stringify({
          method: 'get_hot_news',
          params: {
            platforms: this.platforms
          }
        })
      });

      if (!response.ok) {
        throw new Error(`HTTP error! status: ${response.status}`);
      }

      const data = await response.json();
      return data.result || [];
    } catch (error) {
      console.error('获取热点新闻失败:', error.message);
      return [];
    }
  }

  /**
   * 处理热点数据
   */
  async _fetchAndProcess() {
    const hotTopics = await this._fetchHotNews();
    const now = new Date().toISOString();
    
    console.log(`\n[${now}] 获取到 ${hotTopics.length} 条热点话题`);
    
    for (const topic of hotTopics) {
      await this._processTopic(topic, now);
    }
  }

  /**
   * 处理单个话题
   */
  async _processTopic(topic, timestamp) {
    const topicId = `${topic.platform}-${topic.id}`;
    
    // 检查是否已处理过该话题
    if (this.history.has(topicId)) {
      return;
    }

    // 关键词匹配
    const matchedKeywords = this._matchKeywords(topic);
    
    // 记录到历史
    this.history.set(topicId, {
      ...topic,
      firstDetected: timestamp,
      matchedKeywords
    });

    // 如果有匹配的关键词或热度异常，触发回调
    if (matchedKeywords.length > 0 || this._isAbnormalHotness(topic)) {
      const analysis = this._analyzeTopic(topic, matchedKeywords);
      
      console.log(`🔥 发现热点话题: ${topic.title}`);
      console.log(`   平台: ${topic.platform} | 热度: ${topic.hotness}`);
      console.log(`   匹配关键词: ${matchedKeywords.join(', ') || '无'}`);
      console.log(`   情感倾向: ${analysis.sentiment}`);
      console.log(`   链接: ${topic.url}`);
      
      if (this.onNewHotTopic) {
        this.onNewHotTopic({
          ...topic,
          analysis,
          matchedKeywords,
          timestamp
        });
      }
    }
  }

  /**
   * 关键词匹配
   */
  _matchKeywords(topic) {
    return this.keywords.filter(keyword => {
      const regex = new RegExp(keyword, 'i');
      return regex.test(topic.title) || 
             (topic.description && regex.test(topic.description));
    });
  }

  /**
   * 判断是否热度异常
   */
  _isAbnormalHotness(topic) {
    // 简单判断：热度超过阈值视为异常
    const threshold = this._getPlatformThreshold(topic.platform);
    return topic.hotness > threshold;
  }

  /**
   * 获取平台热度阈值
   */
  _getPlatformThreshold(platform) {
    const thresholds = {
      'weibo': 500000,
      'zhihu': 100000,
      'douyin': 1000000,
      'default': 100000
    };
    return thresholds[platform] || thresholds.default;
  }

  /**
   * 分析话题
   */
  _analyzeTopic(topic, matchedKeywords) {
    // 简单情感分析（基于关键词匹配）
    const positiveWords = ['利好', '增长', '成功', '突破', '创新'];
    const negativeWords = ['争议', '下跌', '失败', '问题', '危机'];
    
    let positiveScore = 0;
    let negativeScore = 0;
    
    const text = `${topic.title} ${topic.description || ''}`;
    
    positiveWords.forEach(word => {
      if (text.includes(word)) positiveScore++;
    });
    
    negativeWords.forEach(word => {
      if (text.includes(word)) negativeScore++;
    });
    
    let sentiment = '中性';
    if (positiveScore > negativeScore) sentiment = '积极';
    else if (negativeScore > positiveScore) sentiment = '消极';
    
    return {
      sentiment,
      positiveScore,
      negativeScore,
      urgency: matchedKeywords.length > 0 || topic.hotness > this._getPlatformThreshold(topic.platform) * 2
    };
  }

  /**
   * 生成监控报告
   */
  generateReport() {
    const totalTopics = this.history.size;
    const urgentTopics = Array.from(this.history.values())
      .filter(topic => 
        topic.matchedKeywords.length > 0 || 
        this._isAbnormalHotness(topic)
      );
    
    const platformStats = {};
    Array.from(this.history.values()).forEach(topic => {
      platformStats[topic.platform] = (platformStats[topic.platform] || 0) + 1;
    });
    
    return {
      timestamp: new Date().toISOString(),
      totalTopics,
      urgentTopics: urgentTopics.length,
      platformStats,
      keywords: this.keywords,
      recentUrgentTopics: urgentTopics.slice(-10).map(topic => ({
        title: topic.title,
        platform: topic.platform,
        hotness: topic.hotness,
        matchedKeywords: topic.matchedKeywords,
        detectedAt: topic.firstDetected
      }))
    };
  }
}

// 使用示例
async function main() {
  // 创建监控实例
  const monitor = new HotNewsMonitor('http://localhost:3000/mcp', {
    keywords: ['科技', '创新', '政策', '市场'],
    platforms: ['weibo', 'zhihu', 'douyin'],
    interval: 600000, // 10分钟检查一次
    onNewHotTopic: (topic) => {
      // 这里可以集成邮件、钉钉、微信通知等
      console.log('🚨 发现相关热点话题，需要关注!');
      console.log(`标题: ${topic.title}`);
      console.log(`平台: ${topic.platform}`);
      console.log(`热度: ${topic.hotness}`);
      console.log(`情感: ${topic.analysis.sentiment}`);
      console.log('---');
      
      // 如果是紧急话题，发送额外通知
      if (topic.analysis.urgency) {
        _sendUrgentNotification(topic);
      }
    }
  });

  // 启动监控
  monitor.start();

  // 每小時生成一次报告
  setInterval(() => {
    const report = monitor.generateReport();
    console.log('\n📊 热点话题监控报告');
    console.log(`统计时间: ${report.timestamp}`);
    console.log(`总话题数: ${report.totalTopics}`);
    console.log(`重要话题数: ${report.urgentTopics}`);
    console.log('各平台分布:', JSON.stringify(report.platformStats, null, 2));
    console.log('最近重要话题:', report.recentUrgentTopics);
  }, 3600000);

  // 30分钟后停止监控（演示用）
  setTimeout(() => {
    monitor.stop();
  }, 1800000);
}

// 发送紧急通知（需要根据实际通知渠道实现）
function _sendUrgentNotification(topic) {
  // 这里可以实现邮件、钉钉、微信等通知方式
  // 例如发送邮件：
  // emailService.send({
  //   to: 'team@company.com',
  //   subject: `紧急热点话题: ${topic.title}`,
  //   text: `平台: ${topic.platform}\n热度: ${topic.hotness}\n链接: ${topic.url}`
  // });
}

// 运行示例
if (require.main === module) {
  main().catch(console.error);
}

module.exports = HotNewsMonitor;

npm install axios

docker run -d -p 3000:3000 --name hotnews mcp/hotnews-server

node hotnews-monitor.js