小明：嘿，小红，我最近在做一个项目，需要实现不同系统之间的数据交换。你有什么建议吗？
小红：你可以考虑使用数据交换平台，它可以帮助你标准化数据格式，提高系统的互操作性。
小明：听起来不错，但具体怎么实现呢？有没有什么技术推荐？
小红：如果你用的是PHP的话，可以尝试用RESTful API来构建这个平台。PHP在Web开发中非常成熟，适合做这样的任务。
小明：那具体要怎么做呢？能给我举个例子吗？
小红：当然可以！我们可以先从一个简单的数据交换接口开始，比如获取用户信息。
小明：好的，那我们先创建一个用户数据表吧。假设数据库里有一个users表，包含id、name和email字段。
小红：没错，接下来我们需要建立一个PHP脚本来处理这个请求。我们可以使用GET方法来获取数据。
小明：那PHP代码应该怎么写呢？
小红：让我给你写一段示例代码。首先，连接数据库，然后查询用户数据，最后返回JSON格式的数据。
// 数据库配置
$host = 'localhost';
$db = 'test_db';
$user = 'root';
$pass = '';
// 连接数据库
$pdo = new PDO("mysql:host=$host;dbname=$db", $user, $pass);
// 获取用户ID
$id = isset($_GET['id']) ? $_GET['id'] : null;
if ($id) {
// 查询用户信息
$stmt = $pdo->prepare("SELECT id, name, email FROM users WHERE id = ?");
$stmt->execute([$id]);
$user = $stmt->fetch(PDO::FETCH_ASSOC);
if ($user) {
echo json_encode($user);
} else {
http_response_code(404);
echo json_encode(['error' => 'User not found']);
}
} else {
http_response_code(400);
echo json_encode(['error' => 'Missing user ID']);
}
?>
小明：这段代码看起来很基础，但确实实现了基本功能。不过，如果我要支持POST请求呢？比如添加新用户？
小红：那我们可以再写一个处理POST请求的脚本。比如，接收JSON数据，插入到数据库中。
小明：好的，那我应该怎么处理POST请求的数据呢？
小红：可以用file_get_contents('php://input')来获取原始输入数据，然后解析成数组。
小明：明白了，那我可以这样写代码：
// 数据库配置
$host = 'localhost';
$db = 'test_db';
$user = 'root';
$pass = '';
// 连接数据库
$pdo = new PDO("mysql:host=$host;dbname=$db", $user, $pass);
// 获取原始输入数据
$data = json_decode(file_get_contents('php://input'), true);
if (isset($data['name']) && isset($data['email'])) {
// 插入新用户
$stmt = $pdo->prepare("INSERT INTO users (name, email) VALUES (?, ?)");
$stmt->execute([$data['name'], $data['email']]);
echo json_encode(['success' => true, 'message' => 'User added successfully']);
} else {
http_response_code(400);
echo json_encode(['error' => 'Missing required fields']);
}
?>
小明：这太棒了！现在我们可以用GET获取数据，用POST添加数据了。但是，如果我要支持PUT或DELETE呢？
小红：那我们可以根据HTTP方法来区分操作。比如，PUT用于更新用户信息，DELETE用于删除用户。
小明：那具体怎么判断是哪个方法呢？
小红：可以用$_SERVER['REQUEST_METHOD']来获取请求方法，然后进行分支处理。
小明：好的，那我来试试写一个处理PUT请求的代码，用来更新用户信息。
// 数据库配置
$host = 'localhost';
$db = 'test_db';
$user = 'root';
$pass = '';
// 连接数据库
$pdo = new PDO("mysql:host=$host;dbname=$db", $user, $pass);
// 获取原始输入数据
$data = json_decode(file_get_contents('php://input'), true);
// 获取用户ID
$id = isset($_GET['id']) ? $_GET['id'] : null;
if ($_SERVER['REQUEST_METHOD'] === 'PUT' && $id && isset($data['name']) && isset($data['email'])) {
// 更新用户信息
$stmt = $pdo->prepare("UPDATE users SET name = ?, email = ? WHERE id = ?");
$stmt->execute([$data['name'], $data['email'], $id]);
echo json_encode(['success' => true, 'message' => 'User updated successfully']);
} else {
http_response_code(400);
echo json_encode(['error' => 'Invalid request or missing data']);
}
?>
小明：这又是一个完整的接口！看来我已经有了一个初步的数据交换平台了。
小红：是的，不过你还得考虑安全性问题。比如，防止SQL注入、验证输入数据、设置CORS等。
小明：对啊，这些都很重要。那我应该怎么做呢？
小红：首先，使用PDO的预处理语句可以防止SQL注入。其次，对于用户输入的数据，要做严格的验证。
小明：那CORS又是什么？我应该怎么处理？
小红：CORS（跨域资源共享）是浏览器的安全机制，防止恶意网站访问你的API。你可以在响应头中设置Access-Control-Allow-Origin，允许特定的域名访问。
小明：明白了，那我可以这样写代码来设置CORS：
header("Access-Control-Allow-Origin: *");
header("Content-Type: application/json");
小明：这样就能让其他域名的前端应用访问我的API了。
小红：没错。另外，还可以考虑使用Token认证来增强安全性。比如，每个请求都携带一个Token，服务器验证后才允许操作。
小明：那Token怎么生成和验证呢？
小红：可以用JWT（JSON Web Token），PHP有现成的库可以使用。比如，使用firebase/php-jwt这个包。
小明：好的，那我是不是还需要一个登录接口来生成Token？
小红：是的，用户登录成功后，服务器生成一个JWT Token，并返回给客户端。之后的请求都需要带上这个Token。
小明：那我可以这样写登录接口的代码：
// 引入JWT库
require 'vendor/autoload.php';
use Firebase\JWT\JWT;
// 数据库配置
$host = 'localhost';
$db = 'test_db';
$user = 'root';
$pass = '';
// 连接数据库
$pdo = new PDO("mysql:host=$host;dbname=$db", $user, $pass);
// 获取用户输入
$data = json_decode(file_get_contents('php://input'), true);
if (isset($data['username']) && isset($data['password'])) {
// 查询用户
$stmt = $pdo->prepare("SELECT id, name FROM users WHERE username = ?");
$stmt->execute([$data['username']]);
$user = $stmt->fetch(PDO::FETCH_ASSOC);
if ($user && password_verify($data['password'], $user['password'])) {
// 生成JWT Token
$key = "your-secret-key";
$payload = [
'iss' => 'your-api',
'exp' => time() + 3600,
'data' => ['id' => $user['id'], 'name' => $user['name']]
];
$token = JWT::encode($payload, $key);
echo json_encode(['token' => $token]);
} else {
http_response_code(401);
echo json_encode(['error' => 'Invalid credentials']);
}
} else {
http_response_code(400);
echo json_encode(['error' => 'Missing username or password']);
}
?>
小明：这样就实现了基于Token的认证。那后续的请求都要带上这个Token。
小红：没错，前端在每次请求时，都要在Header中加上Authorization: Bearer {token}，后端则验证这个Token的有效性。
小明：那怎么验证Token呢？
小红：可以使用JWT库来解码并验证Token的签名和有效期。比如，在每个请求的开头，检查Token是否有效。
小明：那我可以这样写验证代码：
// 检查Token
$token = $_SERVER['HTTP_AUTHORIZATION'] ?? '';
if (!$token) {
http_response_code(401);
echo json_encode(['error' => 'Missing token']);
exit();
}
$key = "your-secret-key";
try {
$decoded = JWT::decode($token, $key, ['HS256']);
// 继续处理请求
} catch (Exception $e) {
http_response_code(401);
echo json_encode(['error' => 'Invalid token']);
exit();
}
小明：这样就完成了整个数据交换平台的基本架构。
小红：是的，虽然这只是一个小项目，但已经涵盖了数据交换平台的核心功能：增删改查、安全验证、API设计等。
小明：谢谢你，小红！我现在对数据交换平台和PHP的结合有了更深入的理解。
小红：不客气，希望你能继续探索更多高级功能，比如使用OAuth2、微服务架构等，进一步提升平台的扩展性和安全性。