消息推送系统

import org.apache.kafka.clients.consumer.ConsumerRecord;

import org.apache.kafka.clients.consumer.ConsumerRecords;

import org.apache.kafka.clients.consumer.KafkaConsumer;

public class KafkaMessageConsumer {

public static void main(String[] args) {

KafkaConsumer consumer = new KafkaConsumer<>(consumerProps());

consumer.subscribe(Arrays.asList("TENDER_DATA_TOPIC"));

while (true) {

ConsumerRecords records = consumer.poll(Duration.ofMillis(100));

for (ConsumerRecord record : records) {

processRecord(record);

}

}

}

private static Map consumerProps() {

Map props = new HashMap<>();

props.put("bootstrap.servers", "localhost:9092");

props.put("group.id", "tender-group");

props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");

props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");

return props;

}

private static void processRecord(ConsumerRecord record) {

System.out.printf("Key: %s, Value: %s%n", record.key(), record.value());

// 在这里解析并存储到数据库

}

}

]]>

import freemarker.template.Configuration;

import freemarker.template.Template;

import freemarker.template.TemplateException;

import java.io.File;

import java.io.FileWriter;

import java.io.IOException;

import java.util.HashMap;

import java.util.Map;

排课系统

public class TenderDocumentGenerator {

public static void main(String[] args) throws IOException, TemplateException {

Configuration cfg = new Configuration(Configuration.VERSION_2_3_30);

cfg.setDirectoryForTemplateLoading(new File("templates"));

Template template = cfg.getTemplate("tender_template.ftl");

Map dataModel = new HashMap<>();

dataModel.put("projectName", "Example Project");

dataModel.put("budget", "1M USD");

try (FileWriter fileWriter = new FileWriter("output/tender.docx")) {

template.process(dataModel, fileWriter);

}

}

}

]]>