SpringBoot离线应用的5种实现方式

xml 体验AI代码助手 代码解读复制代码<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
<dependency>
    <groupId>com.h2database</groupId>
    <artifactId>h2</artifactId>
    <scope>runtime</scope>
</dependency>

ini 体验AI代码助手 代码解读复制代码# 使用文件模式的H2数据库，支持持久化
spring.datasource.url=jdbc:h2:file:./data/offlinedb
spring.datasource.driverClassName=org.h2.Driver
spring.datasource.username=sa
spring.datasource.password=password
spring.jpa.database-platform=org.hibernate.dialect.H2Dialect

# 自动创建表结构
spring.jpa.hibernate.ddl-auto=update

# 启用H2控制台(开发环境)
spring.h2.console.enabled=true
spring.h2.console.path=/h2-console

less 体验AI代码助手 代码解读复制代码@Entity
@Table(name = "offline_data")
public class OfflineData {
    
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;
    
    private String content;
    
    @Column(name = "is_synced")
    private boolean synced;
    
    @Column(name = "created_at")
    private LocalDateTime createdAt;
    
    // 构造函数、getter和setter
}

csharp 体验AI代码助手 代码解读复制代码@Repository
public interface OfflineDataRepository extends JpaRepository<OfflineData, Long> {
    List<OfflineData> findBySyncedFalse();
}

typescript 体验AI代码助手 代码解读复制代码@Service
public class OfflineDataService {
    
    private final OfflineDataRepository repository;
    
    @Autowired
    public OfflineDataService(OfflineDataRepository repository) {
        this.repository = repository;
    }
    
    // 保存本地数据
    public OfflineData saveData(String content) {
        OfflineData data = new OfflineData();
        data.setContent(content);
        data.setSynced(false);
        data.setCreatedAt(LocalDateTime.now());
        return repository.save(data);
    }
    
    // 获取所有未同步的数据
    public List<OfflineData> getUnsyncedData() {
        return repository.findBySyncedFalse();
    }
    
    // 标记数据为已同步
    public void markAsSynced(Long id) {
        repository.findById(id).ifPresent(data -> {
            data.setSynced(true);
            repository.save(data);
        });
    }
    
    // 当网络恢复时，同步数据到远程服务器
    @Scheduled(fixedDelay = 60000) // 每分钟检查一次
    public void syncDataToRemote() {
        List<OfflineData> unsyncedData = getUnsyncedData();
        if (!unsyncedData.isEmpty()) {
            try {
                // 尝试连接远程服务器
                if (isNetworkAvailable()) {
                    for (OfflineData data : unsyncedData) {
                        boolean syncSuccess = sendToRemoteServer(data);
                        if (syncSuccess) {
                            markAsSynced(data.getId());
                        }
                    }
                }
            } catch (Exception e) {
                // 同步失败，下次再试
                log.error("Failed to sync data: " + e.getMessage());
            }
        }
    }
    
    private boolean isNetworkAvailable() {
        // 实现网络检测逻辑
        try {
            InetAddress address = InetAddress.getByName("api.example.com");
            return address.isReachable(3000); // 3秒超时
        } catch (Exception e) {
            return false;
        }
    }
    
    private boolean sendToRemoteServer(OfflineData data) {
        // 实现发送数据到远程服务器的逻辑
        // 这里使用RestTemplate示例
        try {
            RestTemplate restTemplate = new RestTemplate();
            ResponseEntity<String> response = restTemplate.postForEntity(
                "https://api.example.com/data", 
                data, 
                String.class
            );
            return response.getStatusCode().isSuccessful();
        } catch (Exception e) {
            log.error("Failed to send data: " + e.getMessage());
            return false;
        }
    }
}

kotlin 体验AI代码助手 代码解读复制代码@RestController
@RequestMapping("/api/data")
public class OfflineDataController {
    
    private final OfflineDataService service;
    
    @Autowired
    public OfflineDataController(OfflineDataService service) {
        this.service = service;
    }
    
    @PostMapping
    public ResponseEntity<OfflineData> createData(@RequestBody String content) {
        OfflineData savedData = service.saveData(content);
        return ResponseEntity.ok(savedData);
    }
    
    @GetMapping("/unsynced")
    public ResponseEntity<List<OfflineData>> getUnsyncedData() {
        return ResponseEntity.ok(service.getUnsyncedData());
    }
    
    @PostMapping("/sync")
    public ResponseEntity<String> triggerSync() {
        service.syncDataToRemote();
        return ResponseEntity.ok("Sync triggered");
    }
}