@RequiredArgsConstructor(onConstructor = @__(@Autowired)) public class StorageListen{ private static PropertiesMessage filteredRealtimeData = new PropertiesMessage(); private PeriodStorage periodStorage; @Scheduled(cron="*/1 * * * * ?") @Async("PeriodStorage") public void periodStorage(){ PropertiesMessage clone = (PropertiesMessage)filteredRealtimeData.clone(); Map<String,List<StorageConfig>> map = new HashMap(); List<StorageConfig> list = new ArrayList(); StorageConfig s1 = new StorageConfig(); s1.setValue("1"); StorageConfig s2 = new StorageConfig(); s2.setValue("1"); list.add(s1); list.add(s2); map.put("1",list); periodStorage.storageData(clone); } } @RequiredArgsConstructor(onConstructor = @__(@Autowired)) public class PeriodStorage { private static DeviceProperties filteredRealtimeData = new DeviceProperties(); public void storageData(PropertiesMessage message,Map<String,List<StorageConfig>> map){ map.entrySet().stream().forEach(k -> { k.getValue().parallelStream().forEach(y -> { DeviceProperties clone = (DeviceProperties)filteredRealtimeData.clone(); System.out.println(y.toString()); System.out.println(clone.toString()); }) }) } } @Data public class PropertiesMessage implements Serializable { public Map<String, DeviceProperties> propertiesMap; public PropertiesMessage deepClone() { try { ByteArrayOutputStream bos = new ByteArrayOutputStream(); ObjectOutputStream oos = new ObjectOutputStream(bos); oos.writeObject(this); ByteArrayInputStream bis = new ByteArrayInputStream(bos.toByteArray()); ObjectInputStream ois = new ObjectInputStream(bis); return (PropertiesMessage) ois.readObject(); } catch (IOException | ClassNotFoundException e) { e.printStackTrace(); return null; } } } public class DeviceProperties implements Serializable { public String value; public DeviceProperties deepClone() { try { ByteArrayOutputStream bos = new ByteArrayOutputStream(); ObjectOutputStream oos = new ObjectOutputStream(bos); oos.writeObject(this); ByteArrayInputStream bis = new ByteArrayInputStream(bos.toByteArray()); ObjectInputStream ois = new ObjectInputStream(bis); return (DeviceProperties) ois.readObject(); } catch (IOException | ClassNotFoundException e) { e.printStackTrace(); return null; } } } @Data public class StorageConfig{ public String value; }

这段代码是Java语言编写的，主要是实现了一个定时任务，每秒钟执行一次。其中，StorageListen类中的periodStorage()方法是定时任务的具体实现。它通过调用PeriodStorage类的storageData()方法来存储数据。在storageData()方法中，首先使用了Java中的深克隆技术对PropertiesMessage和DeviceProperties对象进行克隆，然后通过遍历map中的键值对，对每个StorageConfig对象进行一些操作。这段代码中还使用了Lombok注解来简化了代码的编写。

相关问题

@RequiredArgsConstructor(onConstructor = @__(@Autowired))修饰类什么意思

@RequiredArgsConstructor(onConstructor = @__(@Autowired))是一个Lombok注解，用于在类中生成一个带有@Autowired注解的构造函数。它的作用是简化代码，自动创建带有@Autowired注解的构造函数，从而实现依赖注入。

在使用Spring框架进行依赖注入时，通常需要在类的构造函数上添加@Autowired注解来标识需要注入的依赖对象。而使用@RequiredArgsConstructor(onConstructor = @__(@Autowired))注解后，Lombok会自动生成带有@Autowired注解的构造函数，省去了手动添加@Autowired注解的步骤。

示例代码如下：

import lombok.RequiredArgsConstructor;
import org.springframework.beans.factory.annotation.Autowired;

@RequiredArgsConstructor(onConstructor = @__(@Autowired))
public class MyClass {
    private final Dependency dependency;
}

以上代码等价于手动编写以下构造函数：

public class MyClass {
    private final Dependency dependency;

    @Autowired
    public MyClass(Dependency dependency) {
        this.dependency = dependency;
    }
}

这样，当使用MyClass类时，Spring容器会自动注入Dependency对象到构造函数中。

@RequiredArgsConstructor(onConstructor = @__(@Autowired)) public class StorageListen{ private static PropertiesMessage filteredRealtimeData = new PropertiesMessage(); private PeriodStorage periodStorage; @Scheduled(cron="*/1 * * * * ?") @Async("PeriodStorage") public void periodStorage(){ PropertiesMessage clone = (PropertiesMessage)filteredRealtimeData.clone(); Map<String,List<StorageConfig>> map = new HashMap(); List<StorageConfig> list = new ArrayList(); StorageConfig s1 = new StorageConfig(); s1.setValue("1"); StorageConfig s2 = new StorageConfig(); s2.setValue("1"); list.add(s1); list.add(s2); map.put("1",list); periodStorage.storageData(clone); } } @RequiredArgsConstructor(onConstructor = @__(@Autowired)) public class PeriodStorage { private static DeviceProperties filteredRealtimeData = new DeviceProperties(); public void storageData(PropertiesMessage message,Map<String,List<StorageConfig>> map){ map.entrySet().stream().forEach(k -> { k.getValue().parallelStream().forEach(y -> { DeviceProperties clone = (DeviceProperties)filteredRealtimeData.clone(); }) }) } } @Data public class PropertiesMessage implements Serializable { public Map<String, DeviceProperties> propertiesMap; public PropertiesMessage deepClone() { try { ByteArrayOutputStream bos = new ByteArrayOutputStream(); ObjectOutputStream oos = new ObjectOutputStream(bos); oos.writeObject(this); ByteArrayInputStream bis = new ByteArrayInputStream(bos.toByteArray()); ObjectInputStream ois = new ObjectInputStream(bis); return (PropertiesMessage) ois.readObject(); } catch (IOException | ClassNotFoundException e) { e.printStackTrace(); return null; } } } public class DeviceProperties implements Serializable { public String value; public DeviceProperties deepClone() { try { ByteArrayOutputStream bos = new ByteArrayOutputStream(); ObjectOutputStream oos = new ObjectOutputStream(bos); oos.writeObject(this); ByteArrayInputStream bis = new ByteArrayInputStream(bos.toByteArray()); ObjectInputStream ois = new ObjectInputStream(bis); return (DeviceProperties) ois.readObject(); } catch (IOException | ClassNotFoundException e) { e.printStackTrace(); return null; } } } @Data public class StorageConfig{ public String value; }

这段代码中的StorageListen类中有一个periodStorage方法，使用@Scheduled注解和@Async注解标记，表示该方法会在固定的时间间隔内执行，并且会在异步线程中执行。该方法会将filteredRealtimeData对象进行克隆，然后将克隆后的对象传递给PeriodStorage类中的storageData方法进行处理。在storageData方法中，会对传递进来的map进行遍历，然后对每个元素进行克隆，并进行相应的处理。

在这段代码中，使用了深克隆的方式来复制对象，以避免修改原始对象。同时，在StorageConfig和DeviceProperties类中也实现了deepClone方法，以支持深克隆。这样可以确保在进行对象复制时，所有的字段都会被正确地复制，并且不会对原始对象造成影响。

需要注意的是，在使用深克隆的方式复制对象时，需要确保对象中的所有字段都是可序列化的，否则会导致克隆失败。此外，由于深克隆需要进行对象的序列化和反序列化操作，因此可能会对性能产生一定的影响，需要在性能和正确性之间进行权衡。