373 lines
13 KiB
Markdown
373 lines
13 KiB
Markdown
这是一个非常棒的功能扩展。这样你的主机不仅是“广播站”，还是所有从机的“剪切板收集中心”。
|
||
|
||
为了实现这个需求，我们需要对架构做如下调整：
|
||
|
||
1. **双向通信**：从机 (Slave) 也需要监听本地剪切板，并将内容发回 Redis。
|
||
2. **上传通道**：新增一个公共的 Redis 频道（如 `clip_upload_channel`），所有从机都往这里发。
|
||
3. **主机接收**：主机 (Master) 启动一个额外的 Redis 监听线程，收到数据后写入文件。
|
||
|
||
以下是修改后的完整方案和代码。
|
||
|
||
---
|
||
|
||
### 1. 修改后的架构逻辑
|
||
|
||
* **Master (主机)**:
|
||
* 线程 1：监听本地剪切板 -> 广播给指定 Slave (原功能)。
|
||
* **线程 2 (新)**：订阅 `clip_upload_channel` -> 解析消息 -> **写入 TXT 文件**。
|
||
|
||
|
||
* **Slave (从机)**:
|
||
* 线程 1：订阅自己的频道 -> 写入本地剪切板 (原功能)。
|
||
* **线程 2 (新)**：监听本地剪切板 -> 加上本机标识 -> 发布到 `clip_upload_channel`。
|
||
|
||
|
||
|
||
---
|
||
|
||
### 2. 配置文件更新 (`config.properties`)
|
||
|
||
我们需要在配置文件中明确从机的“名称”（用于生成文件名，你可以填 IP）。
|
||
|
||
```properties
|
||
# ================= 基础配置 =================
|
||
role=MASTER
|
||
redis.host=127.0.0.1
|
||
redis.port=6379
|
||
redis.password=
|
||
|
||
# ================= 同步配置 =================
|
||
# 【从机配置】
|
||
# 1. 监听哪个频道接收主机的命令
|
||
slave.listen.channel=machine_a
|
||
# 2. (新) 本机标识 (可以是IP，也可以是别名)。
|
||
# 主机收到数据后，会保存为 "这个名字.txt" (例如 192.168.1.50.txt)
|
||
slave.id=192.168.1.50
|
||
|
||
# 【主机配置】
|
||
# 1. 同步目标列表
|
||
master.target.channels=machine_a,machine_b
|
||
# 2. (新) 上传数据保存的根目录 (不填默认在 jar 包同级目录)
|
||
master.save.dir=./clipboard_logs/
|
||
|
||
```
|
||
|
||
---
|
||
|
||
### 3. 完整代码 (`RedisClipSync.java`)
|
||
|
||
这个版本整合了双向逻辑。为了防止“死循环”（主机发给从机 -> 从机写入剪切板 -> 从机监听到变化又发回给主机），我们加了更严格的逻辑判断。
|
||
|
||
```java
|
||
import redis.clients.jedis.Jedis;
|
||
import redis.clients.jedis.JedisPubSub;
|
||
|
||
import java.awt.*;
|
||
import java.awt.datatransfer.*;
|
||
import java.io.*;
|
||
import java.nio.charset.StandardCharsets;
|
||
import java.nio.file.Files;
|
||
import java.nio.file.Paths;
|
||
import java.nio.file.StandardOpenOption;
|
||
import java.text.SimpleDateFormat;
|
||
import java.util.Date;
|
||
import java.util.Properties;
|
||
|
||
public class RedisClipSync {
|
||
|
||
// 配置项
|
||
private static String ROLE;
|
||
private static String REDIS_HOST;
|
||
private static int REDIS_PORT;
|
||
private static String REDIS_PASS;
|
||
|
||
// 主机专用配置
|
||
private static String[] MASTER_TARGETS;
|
||
private static String MASTER_SAVE_DIR;
|
||
|
||
// 从机专用配置
|
||
private static String SLAVE_LISTEN_CHANNEL;
|
||
private static String SLAVE_ID; // 用于生成文件名，如 192.168.1.5.txt
|
||
|
||
// 公共上传通道
|
||
private static final String UPLOAD_CHANNEL = "global_clip_upload";
|
||
|
||
// 状态控制
|
||
private static String lastContent = "";
|
||
private static volatile boolean isRemoteUpdate = false; // 锁标记，防止回环
|
||
|
||
public static void main(String[] args) {
|
||
loadConfig();
|
||
createDirIfMaster();
|
||
|
||
System.out.println(">>> JClipSync Pro 启动 <<<");
|
||
System.out.println("角色: " + ROLE);
|
||
|
||
if ("MASTER".equalsIgnoreCase(ROLE)) {
|
||
// 1. 监听本地 -> 广播给从机
|
||
startClipboardPoller("MASTER", (content) -> {
|
||
publishToSlaves(content);
|
||
});
|
||
// 2. 监听上传通道 -> 写入文件
|
||
startMasterUploadListener();
|
||
} else {
|
||
// 1. 监听 Redis -> 写入本地
|
||
startSlaveDownloadListener();
|
||
// 2. 监听本地 -> 上传给主机 (存文件)
|
||
startClipboardPoller("SLAVE", (content) -> {
|
||
uploadToMaster(content);
|
||
});
|
||
}
|
||
}
|
||
|
||
// ==========================================
|
||
// 公共模块: 剪切板轮询
|
||
// ==========================================
|
||
interface ClipCallback { void onCopy(String content); }
|
||
|
||
private static void startClipboardPoller(String sourceName, ClipCallback callback) {
|
||
Clipboard clipboard = Toolkit.getDefaultToolkit().getSystemClipboard();
|
||
new Thread(() -> {
|
||
System.out.println("[" + sourceName + "] 剪切板监听已启动...");
|
||
while (true) {
|
||
try {
|
||
Thread.sleep(500);
|
||
// 如果刚被远程写入，则跳过本次检测，防止死循环
|
||
if (isRemoteUpdate) {
|
||
isRemoteUpdate = false;
|
||
// 更新本地缓存，认为当前内容是已知的
|
||
Transferable c = clipboard.getContents(null);
|
||
if(c != null && c.isDataFlavorSupported(DataFlavor.stringFlavor)) {
|
||
lastContent = (String) c.getTransferData(DataFlavor.stringFlavor);
|
||
}
|
||
continue;
|
||
}
|
||
|
||
Transferable contents = clipboard.getContents(null);
|
||
if (contents != null && contents.isDataFlavorSupported(DataFlavor.stringFlavor)) {
|
||
String currentText = (String) contents.getTransferData(DataFlavor.stringFlavor);
|
||
|
||
if (!currentText.equals(lastContent)) {
|
||
lastContent = currentText;
|
||
// 触发回调
|
||
callback.onCopy(currentText);
|
||
}
|
||
}
|
||
} catch (Exception e) { /* 忽略 */ }
|
||
}
|
||
}).start();
|
||
}
|
||
|
||
// ==========================================
|
||
// Master 逻辑
|
||
// ==========================================
|
||
|
||
// 动作：广播给所有从机
|
||
private static void publishToSlaves(String content) {
|
||
System.out.println("[Master] 本地复制，广播中...");
|
||
Jedis jedis = getJedis();
|
||
try {
|
||
for (String channel : MASTER_TARGETS) {
|
||
jedis.publish(channel.trim(), content);
|
||
}
|
||
} catch(Exception e) { e.printStackTrace(); }
|
||
finally { if(jedis!=null) jedis.close(); }
|
||
}
|
||
|
||
// 动作：监听上传通道并存文件
|
||
private static void startMasterUploadListener() {
|
||
new Thread(() -> {
|
||
while(true) {
|
||
try (Jedis jedis = getJedis()) {
|
||
System.out.println("[Master] 等待从机上传数据...");
|
||
jedis.subscribe(new JedisPubSub() {
|
||
@Override
|
||
public void onMessage(String channel, String message) {
|
||
// 消息格式约定: "SLAVE_ID|||CONTENT"
|
||
String[] parts = message.split("\\|\\|\\|", 2);
|
||
if (parts.length == 2) {
|
||
String slaveId = parts[0];
|
||
String content = parts[1];
|
||
saveToFile(slaveId, content);
|
||
}
|
||
}
|
||
}, UPLOAD_CHANNEL);
|
||
} catch (Exception e) {
|
||
System.err.println("[Master] Redis 断开，重连中...");
|
||
try { Thread.sleep(3000); } catch (InterruptedException ig) {}
|
||
}
|
||
}
|
||
}).start();
|
||
}
|
||
|
||
// 动作：保存到文件
|
||
private static void saveToFile(String fileName, String content) {
|
||
try {
|
||
// 确保目录存在
|
||
File dir = new File(MASTER_SAVE_DIR);
|
||
if (!dir.exists()) dir.mkdirs();
|
||
|
||
// 文件路径：MASTER_SAVE_DIR/192.168.1.50.txt
|
||
File file = new File(dir, fileName + ".txt");
|
||
|
||
// 格式：[时间] 内容
|
||
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
||
String logEntry = String.format("[%s]\n%s\n\n------------------\n\n", sdf.format(new Date()), content);
|
||
|
||
// 追加写入 (Append)
|
||
Files.write(file.toPath(), logEntry.getBytes(StandardCharsets.UTF_8), StandardOpenOption.CREATE, StandardOpenOption.APPEND);
|
||
|
||
System.out.println("[Master] 已保存来自 [" + fileName + "] 的数据");
|
||
} catch (IOException e) {
|
||
System.err.println("文件写入失败: " + e.getMessage());
|
||
}
|
||
}
|
||
|
||
// ==========================================
|
||
// Slave 逻辑
|
||
// ==========================================
|
||
|
||
// 动作：上传到 Master
|
||
private static void uploadToMaster(String content) {
|
||
System.out.println("[Slave] 检测到复制，正在上传给主机...");
|
||
try (Jedis jedis = getJedis()) {
|
||
// 使用 ||| 作为分隔符，防止内容里有普通的 |
|
||
String payload = SLAVE_ID + "|||" + content;
|
||
jedis.publish(UPLOAD_CHANNEL, payload);
|
||
} catch (Exception e) {
|
||
System.err.println("上传失败: " + e.getMessage());
|
||
}
|
||
}
|
||
|
||
// 动作：接收主机指令
|
||
private static void startSlaveDownloadListener() {
|
||
new Thread(() -> {
|
||
while(true) {
|
||
try (Jedis jedis = getJedis()) {
|
||
System.out.println("[Slave] 监听主机同步...");
|
||
jedis.subscribe(new JedisPubSub() {
|
||
@Override
|
||
public void onMessage(String channel, String message) {
|
||
System.out.println("[Slave] 收到主机内容，写入剪切板");
|
||
writeToClipboard(message);
|
||
}
|
||
}, SLAVE_LISTEN_CHANNEL);
|
||
} catch (Exception e) {
|
||
try { Thread.sleep(3000); } catch (InterruptedException ig) {}
|
||
}
|
||
}
|
||
}).start();
|
||
}
|
||
|
||
private static void writeToClipboard(String text) {
|
||
isRemoteUpdate = true; // 标记：这是远程来的，不要回传！
|
||
try {
|
||
Clipboard clipboard = Toolkit.getDefaultToolkit().getSystemClipboard();
|
||
clipboard.setContents(new StringSelection(text), null);
|
||
} catch (Exception e) { isRemoteUpdate = false; }
|
||
}
|
||
|
||
// ==========================================
|
||
// 辅助工具
|
||
// ==========================================
|
||
private static Jedis getJedis() {
|
||
Jedis jedis = new Jedis(REDIS_HOST, REDIS_PORT);
|
||
if (REDIS_PASS != null && !REDIS_PASS.isEmpty()) jedis.auth(REDIS_PASS);
|
||
return jedis;
|
||
}
|
||
|
||
private static void createDirIfMaster() {
|
||
if ("MASTER".equalsIgnoreCase(ROLE)) {
|
||
File dir = new File(MASTER_SAVE_DIR);
|
||
if(!dir.exists()) dir.mkdirs();
|
||
}
|
||
}
|
||
|
||
private static void loadConfig() {
|
||
try (FileInputStream fis = new FileInputStream("config.properties")) {
|
||
Properties props = new Properties();
|
||
props.load(fis);
|
||
|
||
ROLE = props.getProperty("role", "SLAVE");
|
||
REDIS_HOST = props.getProperty("redis.host", "127.0.0.1");
|
||
REDIS_PORT = Integer.parseInt(props.getProperty("redis.port", "6379"));
|
||
REDIS_PASS = props.getProperty("redis.password", "");
|
||
|
||
MASTER_TARGETS = props.getProperty("master.target.channels", "").split(",");
|
||
MASTER_SAVE_DIR = props.getProperty("master.save.dir", "./clipboard_logs/");
|
||
|
||
SLAVE_LISTEN_CHANNEL = props.getProperty("slave.listen.channel", "default");
|
||
// 如果没填 ID，默认用 listen channel 名字
|
||
SLAVE_ID = props.getProperty("slave.id", SLAVE_LISTEN_CHANNEL);
|
||
|
||
} catch (Exception e) {
|
||
System.err.println("配置加载失败，请检查 config.properties");
|
||
System.exit(1);
|
||
}
|
||
}
|
||
}
|
||
|
||
```
|
||
|
||
---
|
||
|
||
### 4. 部署与使用说明
|
||
|
||
#### A. 目录结构
|
||
|
||
程序启动后，主机端会自动生成文件夹：
|
||
|
||
```text
|
||
/
|
||
- sync.jar
|
||
- config.properties
|
||
- clipboard_logs/ <-- 自动生成
|
||
- 192.168.1.50.txt <-- 从机 A 的记录
|
||
- 192.168.1.51.txt <-- 从机 B 的记录
|
||
|
||
```
|
||
|
||
#### B. 从机配置 (`config.properties`)
|
||
|
||
如果你希望主机生成的文件名是 IP 地址，请务必在 `slave.id` 填入 IP。
|
||
|
||
```properties
|
||
role=SLAVE
|
||
redis.host=192.168.1.100
|
||
# 接收主机同步的频道
|
||
slave.listen.channel=machine_a
|
||
# 发给主机时的身份标识 (决定了主机端生成的文件名)
|
||
slave.id=192.168.1.50
|
||
|
||
```
|
||
|
||
#### C. 主机配置
|
||
|
||
```properties
|
||
role=MASTER
|
||
redis.host=127.0.0.1
|
||
# 同步给哪些机器 (控制下发)
|
||
master.target.channels=machine_a,machine_b
|
||
# 保存接收文件的路径
|
||
master.save.dir=./clipboard_logs/
|
||
|
||
```
|
||
|
||
### 5. 功能验证
|
||
|
||
1. **主机 -> 从机**：主机复制 "Hello Slave"，从机剪切板自动更新。
|
||
2. **从机 -> 主机**：
|
||
* 从机 (192.168.1.50) 复制 "Password123"。
|
||
* 从机剪切板保持 "Password123"。
|
||
* 主机会在 `./clipboard_logs/192.168.1.50.txt` 中追加写入：
|
||
```text
|
||
[2024-05-20 10:00:01]
|
||
Password123
|
||
|
||
------------------
|
||
|
||
```
|
||
|
||
|
||
* **注意**：主机的剪切板**不会**变成 "Password123"（避免干扰主机操作，只做静默记录）。如果你希望主机剪切板也同步变，可以在 `saveToFile` 方法里调用 `writeToClipboard(content)`。
|