MCP Nvd

🚀 NVD Real - time Vulnerability Monitoring Service

This project provides a real - time vulnerability monitoring service based on Uvicorn and SSE (Server - Sent Events). It can communicate with front - ends or other clients in real - time via the WebSocket protocol, using the NVD (National Vulnerability Database) as the data source.

🚀 Quick Start

Installation

1. Clone the project:

git clone https://github.com/your-username/mcp-nvd.git
cd mcp-nvd

2. Install dependencies:

pip install -r requirements.txt

Start the service

Start the service (default binding address is 0.0.0.0:9090, using SSE mode):

uvicorn mcp_nvd.main:app --host 0.0.0.0 --port 9090

Access the service

• Test interface: Send a test message to the specified endpoint.
• Real - time data stream: Connect via a WebSocket client or a browser that supports SSE to get real - time data.

✨ Features

1. Real - time data transmission: Using SSE technology, it supports long - term connections and real - time data push.
2. Multi - platform compatibility: Supports both HTTP and WebSocket protocols simultaneously to meet the needs of different clients.
3. Flexible configuration:
   • Allows customizing the binding address, port number, and logging level.
   • Supports setting the maximum number of bytes per message (default is unlimited).
4. High - performance: Based on Uvicorn's asynchronous framework, it performs well in handling high - concurrency requests.

💻 Usage Examples

Basic Usage

In main.py, you can configure the server as follows:

app = FastAPI(
    title="NVD Vulnerability Monitoring Service",
    description="Real - time vulnerability monitoring system based on SSE",
    version="1.0.0",
)

# Example startup command:
uvicorn mcp_nvd.main:app --host 0.0.0.0 --port 9090

Advanced Usage

Here is a simple usage example:

@app.websocket("/ws")
async def websocket_endpoint(websocket: WebSocket):
    await websocket.accept()
    try:
        while True:
            # Send a message to the specified endpoint
            await websocket.send_text("Data update: {}".format(datetime.now()))
            await asyncio.sleep(1)
    except Exception as e:
        print(f"WebSocket connection closed, error: {e}")

📚 Documentation

Project Structure

mcp-nvd/
├── mcp_nvd/          # Core service code
│   ├── main.py       # FastAPI application entry point
│   └── tools.py      # Auxiliary functions and configuration items
├── requirements.txt  # Dependency management file
└── README.md         # Project documentation

Contributors

• @your-username - Project author
• @contributor1 - Function implementer

Acknowledgments

Thanks to @sidharthrajaram for providing a reference implementation for the SSE - based MCP client and server: https://github.com/sidharthrajaram/mcp-sse

⚠️ Important Note

• Dependency management: Make sure to install all necessary dependencies, including fastapi, uvicorn, and sseclient.
• Security issues: When using this project as an internal tool, pay attention to network security. It is recommended to enable HTTPS in the production environment.
• Performance optimization: Adjust the server configuration according to actual needs, such as increasing the number of threads or optimizing the data push frequency.