消息推送系统

public class TrademarkApplication {

private String applicationId;

private String applicantName;

private String trademarkName;

private String description;

private Date submissionDate;

// 构造函数、getter 和 setter 方法

}

import org.apache.kafka.clients.producer.KafkaProducer;

import org.apache.kafka.clients.producer.ProducerRecord;

import java.util.Properties;

public class TrademarkProducer {

public static void main(String[] args) {

Properties props = new Properties();

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

props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");

props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

KafkaProducer producer = new KafkaProducer<>(props);

String topic = "trademark_applications";

String message = "{\"applicationId\": \"T123456\", \"applicantName\": \"张三\", \"trademarkName\": \"品牌A\", \"description\": \"这是品牌A的描述\", \"submissionDate\": \"2025-04-05\"}";

ProducerRecord record = new ProducerRecord<>(topic, message);

producer.send(record);

producer.close();

}

}

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

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

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

import java.util.Arrays;

import java.util.Properties;

public class TrademarkConsumer {

public static void main(String[] args) {

Properties props = new Properties();

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

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

props.put("enable.auto.commit", "true");

props.put("auto.offset.reset", "earliest");

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

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

KafkaConsumer consumer = new KafkaConsumer<>(props);

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

while (true) {

ConsumerRecords records = consumer.poll(100);

for (ConsumerRecord record : records) {

System.out.println("收到消息：" + record.value());

// 这里可以调用商标管理系统的接口，将数据保存或更新

}

}

}

}

// 生成 JWT

import io.jsonwebtoken.Jwts;

import io.jsonwebtoken.SignatureAlgorithm;

import java.util.Date;

public class JwtUtil {

private static final String SECRET_KEY = "your-secret-key";

private static final long EXPIRATION_TIME = 86400000; // 24小时

public static String generateToken(String userId) {

return Jwts.builder()

.setSubject(userId)

.setExpiration(new Date(System.currentTimeMillis() + EXPIRATION_TIME))

.signWith(SignatureAlgorithm.HS512, SECRET_KEY)

.compact();

}

public static String parseToken(String token) {

return Jwts.parser()

.setSigningKey(SECRET_KEY)

.parseClaimsJws(token)

.getBody()

.getSubject();

}

}