Comment mettre en œuvre une surveillance de la sécurité IoT en temps réel à l'aide de PHP et Kafka

Le développement rapide de l'Internet des objets nous a apporté beaucoup de commodité, mais il a également entraîné de nombreux risques pour la sécurité. Dans le système Internet des objets, il existe un grand nombre d'appareils, différents types d'appareils, et le système est vaste et complexe. Comment assurer la sécurité du réseau est devenu une question très importante. Cet article vous aidera à mieux protéger la sécurité du système IoT en vous expliquant comment utiliser PHP et Kafka pour mettre en œuvre une surveillance de la sécurité IoT en temps réel.

1. Que sont PHP et Kafka

PHP est un langage de script open source polyvalent, principalement utilisé pour le développement Web. Il peut être intégré dans HTML et prend également en charge diverses opérations de base de données. PHP est facile à apprendre et présente de faibles barrières à l’entrée, il est donc largement utilisé dans le domaine du développement Web.

Kafka est un système de file d'attente de messages distribué, principalement utilisé dans des scénarios de traitement de données à grande échelle. Kafka peut réaliser des fonctions telles que la transmission, le traitement et le stockage de messages, et présente les caractéristiques d'une grande fiabilité et de hautes performances. Kafka est principalement écrit en Scala, mais il existe également un client Kafka pour le langage PHP.

2. Solution de surveillance de la sécurité du système Internet des objets

Pour réaliser la surveillance de la sécurité du système Internet des objets, les aspects suivants doivent être pris en compte :

1. Collecte de données : collecter les données générées par divers appareils et capteurs sur Internet. of Things, y compris des données clés telles que l'état de l'appareil, son état de santé et l'utilisation du trafic.

2. Traitement des données : analyser, analyser et traiter les données collectées et extraire des informations clés, telles que des informations sur les anomalies de l'appareil, des informations sur les attaques de réseau, etc.

3. Transmission des données : lors de la transmission des informations traitées au centre de surveillance, la manière de garantir le temps réel et l'exactitude des informations est une considération importante.

4. Stockage des données : stockez les données de surveillance dans la base de données pour une meilleure analyse et une meilleure exploitation, et améliorez l'efficacité et les performances de la surveillance.

5. Avertissement anormal : lorsque le système de surveillance détecte une situation anormale, il doit émettre un avertissement en temps opportun afin que l'administrateur puisse prendre des mesures en temps opportun.

3. Utilisez PHP et Kafka pour réaliser une surveillance de la sécurité de l'IoT en temps réel

Ce qui suit présente comment utiliser PHP et Kafka pour réaliser une surveillance en temps réel de chaque aspect de la solution de surveillance de la sécurité du système IoT :

1. collection

Things Les appareils et les capteurs du système en réseau peuvent communiquer avec le serveur principal via des protocoles tels que MQTT et CoAP et télécharger des données. Le serveur backend peut utiliser l'interface API RESTful pour recevoir des données et les télécharger. En PHP, vous pouvez utiliser la bibliothèque cURL pour gérer les requêtes HTTP. Voici un exemple simple de code PHP :

$url = "http://example.com/api/data"; //API接口地址
$data = array(
  'device_id' => '123',
  'timestamp' => '1621557645',
  'data' => array(
    'temperature' => 25,
    'humidity' => 50,
    'light' => 100
  )
);

$options = array(
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_POST => true,
  CURLOPT_POSTFIELDS => json_encode($data),
  CURLOPT_HTTPHEADER => array('Content-Type: application/json'),
);

$ch = curl_init($url);
curl_setopt_array($ch, $options);
$response = curl_exec($ch);
curl_close($ch);

echo $response;

2. Traitement des données

PHP lui-même est un langage de script qui peut facilement traiter des données. Le traitement des données peut être effectué via les fonctions et extensions intégrées de PHP, ou via des fonctions personnalisées. Voici un exemple de code PHP simple :

$data = '{"device_id":"123","timestamp":"1621557645","data":{"temperature":25,"humidity":50,"light":100}}';

$json = json_decode($data, true); //将JSON转成PHP数组
$temperature = $json['data']['temperature'];
$humidity = $json['data']['humidity'];
$light = $json['data']['light'];

if ($temperature > 30) {
  echo "Warning: Temperature too high!";
}

if ($humidity > 80) {
  echo "Warning: Humidity too high!";
}

if ($light < 50) {
  echo "Warning: Light too low!";
}

3. Transmission de données

Kafka est un système de file d'attente de messages distribué qui peut atteindre une concurrence élevée et une haute fiabilité de transmission des messages. Kafka fournit une variété de bibliothèques clientes telles que Java, Scala, Python et PHP pour faciliter la livraison des messages. Voici un exemple de code PHP simple :

$config = KafkaConsumerConfig::getInstance();
$config->setMetadataRefreshIntervalMs(10000);
$config->setMetadataBrokerList('kafka1.example.com:9092,kafka2.example.com:9092,kafka3.example.com:9092');
$config->setGroupId('mygroup');
$consumer = new KafkaConsumer();
$consumer->setLogger(new KafkaLogEchoLogger());

$topics = array('mytopic');
$consumer->subscribe($topics);
while (true) {
  $message = $consumer->consume();
  if (empty($message)) {
    continue;
  }

  $data = json_decode($message->payload, true); //将消息转成PHP数组
  //处理数据逻辑
}

4. Stockage des données

Dans la surveillance en temps réel, il est généralement nécessaire de stocker les données surveillées. MySQL est une base de données relationnelle couramment utilisée avec une bonne capacité à stocker et à gérer des données. Cela peut être fait en utilisant les extensions mysqli ou PDO en PHP. Voici un exemple de code PHP simple :

$host = 'localhost';
$username = 'username';
$password = 'password';
$database = 'mydatabase';

$conn = new mysqli($host, $username, $password, $database);
if ($conn->connect_error) {
  die("Connection failed: " . $conn->connect_error);
}

$sql = "INSERT INTO data (device_id, timestamp, temperature, humidity, light) VALUES (?, ?, ?, ?, ?)";
$stmt = $conn->prepare($sql);
$stmt->bind_param("ssiii", $device_id, $timestamp, $temperature, $humidity, $light);

$device_id = '123';
$timestamp = '1621557645';
$temperature = 25;
$humidity = 50;
$light = 100;
$stmt->execute();

$stmt->close();
$conn->close();

5. Avertissement anormal

Lorsque des données anormales sont détectées, des notifications peuvent être envoyées via diverses méthodes telles que l'e-mail, le SMS ou le push APP. Il existe une variété de bibliothèques tierces en PHP qui peuvent facilement envoyer des e-mails ou des messages texte. Voici un exemple de code PHP simple :

use PHPMailerPHPMailerPHPMailer;

$mail = new PHPMailer();
$mail->isSMTP();
$mail->Host = 'smtp.example.com';
$mail->SMTPAuth = true;
$mail->Username = 'username';
$mail->Password = 'password';
$mail->SMTPSecure = 'tls';
$mail->Port = 587;
$mail->setFrom('from@example.com', 'MyAPP');
$mail->addAddress('to@example.com', 'User');
$mail->Subject = 'Warning: Temperature too high!';
$mail->Body = 'Temperature has reached to 35.0 °C!';
$mail->send();

IV. Résumé

Cet article présente comment utiliser PHP et Kafka pour mettre en œuvre une surveillance de la sécurité IoT en temps réel. Lors de la mise en œuvre de la surveillance du système IoT, plusieurs aspects doivent être pris en compte, tels que la collecte, le traitement, la transmission, le stockage et les alertes anormales des données. PHP est un langage de script facile à apprendre et capable de gérer facilement le traitement des données et d'envoyer des requêtes. Kafka est un système de file d'attente de messages distribué qui peut atteindre une concurrence élevée et une grande fiabilité de transmission des messages. En combinant PHP et Kafka, divers problèmes de surveillance de la sécurité des systèmes IoT peuvent être bien résolus et l'efficacité et les performances de la surveillance peuvent être améliorées.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!