文章目录
- 第6章 接收前台数据
- 6.1 模拟数据
- 6.2 接收数据
- 6.2.1 编写Dao
- 6.2.2 编写ServiceImpl
- 6.2.3 编写Controller
- 6.2.4 验证
- 后记
第6章 接收前台数据
在工作中也会遇到需要接收前台发送数据，进行存储的情况。这里以接收日志服务器的日志数据保存到kafka为例。
6.1 模拟数据
在数据模拟程序中配置日志要发送的url地址：
dest:
logUrl: http://localhost:8080/app
之后重启数据模拟程序。
6.2 接收数据
在数据接口程序中接收日志并写入kafka。
6.2.1 编写Dao
使用SpringBoot提供的KafkaTemplate可以作为客户端生产者向kafka进行生产操作。
6.2.2 编写ServiceImpl
在Service中添加接收数据写入Kafka的方法如下：
public interface DataInterfaceService
{
void sendDataToKafka(String data);
}
编写Service的方法实现：
@Service
public class DataInterfaceServiceImpl implements DataInterfaceService
{
//读取配置文件中dest.topic参数获取要写入的主题
@Value(“${dest.topic}”)
private String topic;
@Autowired
private KafkaTemplate<String,String> kafkaTemplate;
Override
public void sendDataToKafka(String data) {
kafkaTemplate.send(topic,data);
}
｝
6.2.3 编写Controller
默认数据模拟程序发送get请求，参数名为logStr，参考数据模拟程序的配置文件。
@RestController
public class DataInterfaceController
{
@Autowired
private DataInterfaceService dIService;
@GetMapping(value = “/app”)
public void saveLogToKafka(String logStr){
log.info(logStr);
dIService.sendDataToKafka(logStr);
}
}
6.2.4 验证
打开Kafka客户端进行验证：
后记
📢博客主页：https://manor.blog.csdn.net
📢欢迎点赞 👍 收藏 ⭐留言 📝 如有错误敬请指正！
📢本文由 Maynor 原创，首发于 CSDN博客🙉
📢不能老盯着手机屏幕，要不时地抬起头，看看老板的位置⭐
📢数据接口项目持续更新,欢迎订阅：https://blog.csdn.net/xianyu120/category_12433813.html
