消息推送系统

// Kafka生产者示例

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");

Producer producer = new KafkaProducer<>(props);

ProducerRecord record = new ProducerRecord<>("user_actions", "{\"user_id\":1,\"action\":\"score\",\"score\":100}");

producer.send(record);

producer.close();

// Redis更新排行榜示例

Jedis jedis = new Jedis("localhost");

jedis.zadd("leaderboard", 100, "user_1");

Set topUsers = jedis.zrevrange("leaderboard", 0, 9);

for (String user : topUsers) {

System.out.println(user);

}