Java Web开发学习指南：从入门到实战
一、Java Web基础
（一）Java Web简介
- Java Web的概念
- Java Web是基于Java语言开发的Web应用程序。
- 它通过Java技术实现动态网页的生成和数据交互。
- 应用场景
- 企业级Web应用开发，如电子商务网站、在线办公系统、企业资源管理系统等。
- Java Web技术在互联网、金融、教育等多个领域都有广泛应用。
- Java Web与Java SE、Java EE的关系
- Java SE（Java Standard Edition）：是Java的基础，提供了核心库和运行环境，是Java Web开发的基础。
- Java EE（Java Enterprise Edition）：是Java SE的扩展，提供了企业级应用开发的规范和框架，包括Servlet、JSP、EJB等技术，Java Web是Java EE的重要组成部分。
（二）Web开发基础
- HTTP协议
- 请求方法
- GET：用于请求服务器返回指定资源的内容，请求参数通常附加在URL中。
- POST：用于向服务器提交数据，请求参数通常放在请求体中，适用于提交表单数据。
- PUT：用于向服务器请求更新指定资源。
- DELETE：用于请求服务器删除指定资源。
- 状态码及含义
- 200 OK：请求成功，服务器已返回请求的资源。
- 400 Bad Request：请求无效，服务器无法理解请求的格式。
- 404 Not Found：请求的资源不存在。
- 500 Internal Server Error：服务器内部错误，无法处理请求。
- HTML/CSS基础
- HTML标签及属性
- 常用标签：
<html>、<head>、<body>、<div>、<span>、<a>、<form>、<input>等。
- 属性：
id、class、name、src、href等。
- CSS样式表的基本使用
- 内联样式、内部样式表、外部样式表。
- 选择器：标签选择器、类选择器、ID选择器等。
- 样式规则：字体、颜色、边距、布局等。
- JavaScript基础
- 基本语法
- 变量声明、数据类型（字符串、数字、布尔值、数组、对象等）。
- 控制结构（if语句、for循环、while循环等）。
- DOM操作
- 获取元素：
document.getElementById()、document.getElementsByClassName()等。
- 修改元素内容：
innerHTML、textContent。
- 事件绑定：
addEventListener()。
- 事件处理
- 常见事件：点击事件（
click）、鼠标悬停事件（mouseover）、键盘事件（keydown等）。
（三）Servlet基础
- Servlet的概念和作用
- Servlet是运行在服务器端的Java程序，用于处理客户端的请求并返回响应。
- 它是Java Web开发的核心技术之一，用于实现动态网页的生成和数据交互。
- Servlet的生命周期
- 初始化阶段：当Servlet被加载到服务器时，服务器会调用
init()方法进行初始化。
- 请求处理阶段：每次客户端发送请求时，服务器会调用
service()方法处理请求，根据请求类型（GET或POST）调用doGet()或doPost()方法。
- 销毁阶段：当Servlet不再被使用时，服务器会调用
destroy()方法进行资源清理。
- Servlet的配置和部署
- Servlet的请求和响应处理
- 请求处理
- 获取请求参数：
request.getParameter()。
- 获取请求头信息：
request.getHeader()。
- 响应处理
- 设置响应内容类型：
response.setContentType()。
- 写入响应内容：
response.getWriter()或response.getOutputStream()。
（四）JSP基础
- JSP的概念和优势
- JSP（Java Server Pages）是一种基于Java的动态网页技术。
- 它允许将Java代码嵌入到HTML页面中，实现动态内容的生成。
- 优势：易于开发和维护，分离了HTML和Java代码。
- JSP指令
- page指令
- include指令
- taglib指令
- JSP动作元素
<jsp:include>
<jsp:forward>
- JSP内置对象
- request
- response
- 表示服务器的响应，用于设置响应内容类型和写入响应内容。
- session
- application
- out
二、Java Web开发工具与环境
（一）开发工具
- Eclipse/IntelliJ IDEA等IDE的使用
- Eclipse
- 安装和配置：下载Eclipse IDE for Java EE Developers版本，安装并配置Java开发环境。
- 项目创建：通过Eclipse创建Java Web项目，设置项目结构和依赖。
- 代码编写和调试：使用Eclipse的代码编辑器编写Java代码，利用调试工具进行代码调试。
- IntelliJ IDEA
- 安装和配置：下载IntelliJ IDEA Community Edition或Ultimate Edition，安装并配置Java开发环境。
- 项目创建：通过IntelliJ IDEA创建Java Web项目，使用Maven或Gradle管理项目依赖。
- 代码编写和调试：利用IntelliJ IDEA的智能代码提示和强大的调试功能，提高开发效率。
- Maven/Gradle等构建工具的使用
- Maven
- 概念：Maven是一个项目管理和构建自动化工具，基于POM（Project Object Model）文件管理项目依赖和构建生命周期。
- 配置：在项目根目录下创建
pom.xml文件，配置项目依赖和插件。
- 常用命令：
mvn clean：清理项目生成的文件。mvn compile：编译项目源代码。mvn package：打包项目。mvn install：将项目安装到本地仓库。
- Gradle
- 概念：Gradle是一个基于Groovy或Kotlin DSL的构建工具，支持多种编程语言和项目类型。
- 配置：在项目根目录下创建
build.gradle文件，配置项目依赖和任务。
- 常用命令：
gradle build：构建项目。gradle clean：清理项目生成的文件。gradle test：运行项目测试。
（二）Web服务器
- Tomcat服务器的安装与配置
- 安装
- 下载Tomcat服务器的安装包（如
apache-tomcat-9.x.zip），解压到指定目录。
- 配置
conf/server.xml
- 配置服务器端口（如
<Connector port="8080" protocol="HTTP/1.1" />）。
- 配置虚拟主机（如
<Host name="localhost" appBase="webapps" unpackWARs="true" autoDeploy="true" />）。
conf/web.xml
conf/context.xml
- 启动和停止
- 使用
bin/startup.sh（Linux/Mac）或bin/startup.bat（Windows）启动Tomcat。
- 使用
bin/shutdown.sh（Linux/Mac）或bin/shutdown.bat（Windows）停止Tomcat。
- Tomcat的目录结构及工作原理
- 目录结构
bin：包含启动和停止Tomcat的脚本文件。conf：包含Tomcat的配置文件，如server.xml、web.xml等。lib：包含Tomcat运行所需的JAR文件。logs：存放Tomcat运行时生成的日志文件。webapps：存放部署的Web应用。work：存放Tomcat编译后的JSP文件和其他临时文件。
- 工作原理
- 当客户端发送请求到Tomcat时，Tomcat会根据
server.xml中的配置找到对应的虚拟主机和Web应用。
- 如果请求的资源是Servlet，Tomcat会加载和初始化Servlet，调用
service()方法处理请求。
- 如果请求的资源是JSP文件，Tomcat会将JSP文件编译成Servlet，然后执行Servlet处理请求。
（三）数据库连接
- JDBC基础
- 数据库连接的步骤
- 加载数据库驱动：
Class.forName("com.mysql.cj.jdbc.Driver")。
- 建立连接：
DriverManager.getConnection("jdbc:mysql://localhost:3306/mydatabase", "username", "password")。
- 创建
Statement或PreparedStatement对象：connection.createStatement()或connection.prepareStatement(sql)。
- 执行SQL语句：
statement.executeQuery(sql)（查询）或statement.executeUpdate(sql)（更新）。
- 处理结果集：
ResultSet对象。
- 关闭连接和资源：
resultSet.close()、statement.close()、connection.close()。
- 数据库操作（增删改查）
- 插入（Insert）
String sql = "INSERT INTO users (username, password) VALUES (?, ?)";
PreparedStatement ps = connection.prepareStatement(sql);
ps.setString(1, "user1");
ps.setString(2, "password1");
ps.executeUpdate();
- 查询（Select）
String sql = "SELECT * FROM users";
Statement statement = connection.createStatement();
ResultSet resultSet = statement.executeQuery(sql);
while (resultSet.next()) {String username = resultSet.getString("username");String password = resultSet.getString("password");System.out.println(username + " : " + password);
}
- 更新（Update）
String sql = "UPDATE users SET password = ? WHERE username = ?";
PreparedStatement ps = connection.prepareStatement(sql);
ps.setString(1, "newpassword");
ps.setString(2, "user1");
ps.executeUpdate();
- 删除（Delete）
String sql = "DELETE FROM users WHERE username = ?";
PreparedStatement ps = connection.prepareStatement(sql);
ps.setString(1, "user1");
ps.executeUpdate();
- 数据库连接池的使用
- 概念
- 数据库连接池是一种资源管理技术，用于提高数据库连接的复用性和性能。
- 常见的连接池有DBCP、C3P0、HikariCP等。
- 使用方法
三、Java Web开发核心技术
（一）表单处理
- 表单的创建和提交
- HTML表单
- 表单提交方式
- GET：将表单数据附加在URL中，适合简单的查询操作。
- POST：将表单数据放在请求体中，适合提交大量数据或敏感信息。
- 表单数据的接收和处理
- 表单验证
（二）会话管理
- Cookie的使用
- 概念
- Cookie是存储在客户端浏览器中的小文件，用于存储用户会话信息。
- 创建和发送Cookie
Cookie cookie = new Cookie("username", "user1");
cookie.setMaxAge(60 * 60 * 24 * 7); // 设置Cookie的有效期为7天
response.addCookie(cookie);
- 读取Cookie
Cookie[] cookies = request.getCookies();
if (cookies != null) {for (Cookie cookie : cookies) {if ("username".equals(cookie.getName())) {String username = cookie.getValue();System.out.println("用户名：" + username);}}
}
- Session的使用
- 概念
- Session是存储在服务器端的会话对象，用于跟踪用户会话。
- 创建和使用Session
HttpSession session = request.getSession();
session.setAttribute("username", "user1");
- 读取Session中的数据
String username = (String) session.getAttribute("username");
System.out.println("用户名：" + username);
- 销毁Session
session.invalidate();
（三）文件上传与下载
- 文件上传的实现
- 使用Apache Commons FileUpload
- 添加依赖：
<dependency><groupId>commons-fileupload</groupId><artifactId>commons-fileupload</artifactId><version>1.4</version>
</dependency>
- 示例代码：
DiskFileItemFactory factory = new DiskFileItemFactory();
ServletFileUpload upload = new ServletFileUpload(factory);
List<FileItem> items = upload.parseRequest(request);
for (FileItem item : items) {if (!item.isFormField()) {String fileName = item.getName();item.write(new File("upload/" + fileName));}
}
- 文件下载的实现
- 设置响应头
String filePath = "download/file.txt";
File file = new File(filePath);
response.setContentType("application/octet-stream");
response.setHeader("Content-Disposition", "attachment; filename=" + URLEncoder.encode(file.getName(), "UTF-8"));
InputStream inputStream = new FileInputStream(file);
OutputStream outputStream = response.getOutputStream();
byte[] buffer = new byte[1024];
int length;
while ((length = inputStream.read(buffer)) > 0) {outputStream.write(buffer, 0, length);
}
inputStream.close();
outputStream.close();
（四）过滤器与监听器
- 过滤器的概念和作用
- 概念
- 过滤器是Java Web中用于拦截请求和响应的组件，可以对请求进行预处理或对响应进行后处理。
- 作用
- 完成请求的统一编码设置。
- 完成用户身份的验证。
- 完成日志记录等。
- 过滤器的配置和使用
- 配置方式
- 在
web.xml中配置：<filter><filter-name>CharacterEncodingFilter</filter-name><filter-class>com.example.CharacterEncodingFilter</filter-class><init-param><param-name>encoding</param-name><param-value>UTF-8</param-value></init-param>
</filter>
<filter-mapping><filter-name>CharacterEncodingFilter</filter-name><url-pattern>/*</url-pattern>
</filter-mapping>
- 使用注解：
@WebFilter("/*")
public class CharacterEncodingFilter implements Filter {@Overridepublic void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {request.setCharacterEncoding("UTF-8");response.setCharacterEncoding("UTF-8");chain.doFilter(request, response);}
}
- 监听器的概念和作用
- 概念
- 监听器是Java Web中用于监听Web应用事件的组件，可以监听应用的生命周期事件（如应用启动、销毁、会话创建等）。
- 作用
- 初始化应用资源。
- 统计在线人数。
- 监听会话事件等。
- 监听器的配置和使用
- 配置方式
- 在
web.xml中配置：<listener><listener-class>com.example.MyListener</listener-class>
</listener>
- 使用注解：
@WebListener
public class MyListener implements ServletContextListener {@Overridepublic void contextInitialized(ServletContextEvent sce) {System.out.println("应用启动");}@Overridepublic void contextDestroyed(ServletContextEvent sce) {System.out.println("应用销毁");}
}
四、Java Web开发框架
（一）Spring框架
- Spring的核心概念（IoC、AOP）
- IoC（控制反转）
- 将对象的创建和管理交给Spring容器，而不是由程序代码直接创建对象。
- 示例：
@Component
public class MyService {public void doSomething() {System.out.println("Doing something");}
}
public class Main {public static void main(String[] args) {ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");MyService myService = context.getBean(MyService.class);myService.doSomething();}
}
- AOP（面向切面编程）
- Spring的配置方式（XML、注解、Java配置）
- Spring的Bean管理
- Bean的生命周期
- 初始化：
@PostConstruct注解的方法。
- 销毁：
@PreDestroy注解的方法。
- Bean的作用域
singleton：默认作用域，单例模式。prototype：每次请求都创建一个新的Bean实例。request：每次HTTP请求都创建一个新的Bean实例。session：每个HTTP会话都创建一个新的Bean实例。
- Spring的事务管理
- 声明式事务管理
- 使用
@Transactional注解：@Service
public class MyService {@Transactionalpublic void doSomething() {// 业务逻辑}
}
- 配置事务管理器：
@Bean
public PlatformTransactionManager transactionManager(DataSource dataSource) {return new DataSourceTransactionManager(dataSource);
}
（二）Spring MVC框架
- Spring MVC的工作原理
- 客户端发送请求到前端控制器（
DispatcherServlet）。
DispatcherServlet根据请求信息调用处理器映射器（HandlerMapping），找到对应的处理器（Controller）。- 处理器执行业务逻辑，返回
ModelAndView对象。
DispatcherServlet根据ModelAndView对象选择视图解析器（ViewResolver），解析视图名称，渲染视图。- 返回响应给客户端。
- Spring MVC的控制器
- Spring MVC的数据绑定
- 表单数据绑定
- 示例：
@Controller
public class MyController {@RequestMapping("/submit")public String submit(User user) {System.out.println(user.getUsername() + " : " + user.getPassword());return "success";}
}
<form action="/submit" method="post"><label for="username">用户名：</label><input type="text" id="username" name="username" /><label for="password">密码：</label><input type="password" id="password" name="password" /><button type="submit">提交</button>
</form>
- 日期类型绑定
- 配置
@InitBinder方法：@InitBinder
public void initBinder(WebDataBinder binder) {SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");binder.registerCustomEditor(Date.class, new CustomDateEditor(dateFormat, true));
}
- Spring MVC的视图解析
- 配置视图解析器
- 示例（XML配置）：
<bean class="org.springframework.web.servlet.view.InternalResourceViewResolver"><property name="prefix" value="/WEB-INF/views/" /><property name="suffix" value=".jsp" />
</bean>
- 示例（注解配置）：
@Bean
public ViewResolver viewResolver() {InternalResourceViewResolver resolver = new InternalResourceViewResolver();resolver.setPrefix("/WEB-INF/views/");resolver.setSuffix(".jsp");return resolver;
}
（三）MyBatis框架
- MyBatis的基本概念
- MyBatis是一个优秀的持久层框架，支持定制化SQL、存储过程以及高级映射。
- 它通过配置文件和注解将Java对象映射到数据库表。
- MyBatis的配置文件
- MyBatis的映射文件
UserMapper.xml
- 定义SQL语句和Java对象的映射关系。
- 示例：
<mapper namespace="com.example.UserMapper"><select id="selectUserById" parameterType="int" resultType="com.example.User">SELECT * FROM users WHERE id = #{id}</select><insert id="insertUser" parameterType="com.example.User">INSERT INTO users (username, password) VALUES (#{username}, #{password})</insert>
</mapper>
- MyBatis的使用
- 创建SqlSessionFactory
String resource = "mybatis-config.xml";
InputStream inputStream = Resources.getResourceAsStream(resource);
SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
- 获取SqlSession
try (SqlSession session = sqlSessionFactory.openSession()) {UserMapper userMapper = session.getMapper(UserMapper.class);User user = userMapper.selectUserById(1);System.out.println(user.getUsername());
}
（四）Spring Boot
- Spring Boot的特点
- 简化配置
- 独立运行
- 内嵌Tomcat、Jetty等服务器，无需部署WAR文件。
- 微服务支持
- 提供微服务开发的支持，如Spring Cloud。
- Spring Boot的自动配置
- Spring Boot的启动类
- Spring Boot的配置文件
application.properties或application.yml
- 示例（
application.properties）：server.port=8081
spring.datasource.url=jdbc:mysql://localhost:3306/mydatabase
spring.datasource.username=username
spring.datasource.password=password
- 示例（
application.yml）：server:port: 8081
spring:datasource:url: jdbc:mysql://localhost:3306/mydatabaseusername: usernamepassword: password
五、Java Web项目开发
（一）项目架构设计
- MVC架构
- Model（模型）
- View（视图）
- Controller（控制器）
- 用于处理用户请求，调用模型层的业务逻辑，并将结果返回到视图层。
- 分层架构
- 控制层（Controller）
- 服务层（Service）
- 持久层（DAO）
- 实体层（Entity）
（二）项目开发流程
- 需求分析
- 分析项目需求，确定功能模块和业务流程。
- 编写需求文档，明确项目的目标和范围。
- 系统设计
- 设计系统的架构，包括数据库设计、模块划分等。
- 编写设计文档，绘制系统架构图和流程图。
- 编码实现
- 根据设计文档进行编码开发。
- 使用Spring Boot等框架快速搭建项目结构。
- 编写控制器、服务层、持久层代码。
- 测试
- 部署
- 将项目打包为JAR或WAR文件。
- 部署到服务器（如Tomcat、Nginx等）。
- 配置服务器环境，确保项目正常运行。
（三）项目实战
- 完整的Java Web项目开发
- 项目背景
- 以一个简单的在线商城系统为例，实现用户注册、登录、商品浏览、购物车管理、订单提交等功能。
- 项目结构
src/main/java
com.example.controller：控制器类。com.example.service：服务层类。com.example.dao：持久层类。com.example.entity：实体类。
src/main/resources
application.properties：配置文件。mybatis：MyBatis配置文件和映射文件。
src/main/webapp
- 开发步骤
- 创建项目
- 使用Spring Boot Initializr创建项目，添加依赖（Spring Web、MyBatis、MySQL等）。
- 配置数据库
- 在
application.properties中配置数据库连接信息。
- 创建数据库和表。
- 开发用户模块
- 用户注册
- 用户登录
- 创建用户登录页面（
login.jsp）。
- 编写用户登录控制器方法：
@PostMapping("/login")
public String login(String username, String password, Model model) {User user = userService.login(username, password);if (user != null) {model.addAttribute("user", user);return "home";} else {model.addAttribute("error", "用户名或密码错误");return "login";}
}
- 在服务层调用持久层方法查询用户数据。
- 开发商品模块
- 商品列表
- 商品详情
- 创建商品详情页面（
productDetail.jsp）。
- 编写商品详情控制器方法：
@GetMapping("/product/{id}")
public String productDetail(@PathVariable Integer id, Model model) {Product product = productService.getProductById(id);model.addAttribute("product", product);return "productDetail";
}
- 在服务层调用持久层方法查询商品详情数据。
- 开发购物车模块
- 添加到购物车
- 编写添加到购物车的控制器方法：
@PostMapping("/cart/add")
public String addToCart(Integer productId, Integer quantity, HttpSession session) {Cart cart = (Cart) session.getAttribute("cart");if (cart == null) {cart = new Cart();}cart.addProduct(productService.getProductById(productId), quantity);session.setAttribute("cart", cart);return "redirect:/cart";
}
- 在服务层调用持久层方法查询商品数据。
- 购物车列表
- 创建购物车页面（
cart.jsp）。
- 编写购物车列表控制器方法：
@GetMapping("/cart")
public String cart(HttpSession session, Model model) {Cart cart = (Cart) session.getAttribute("cart");if (cart == null) {cart = new Cart();}model.addAttribute("cart", cart);return "cart";
}
- 在购物车页面显示购物车中的商品列表。
- 开发订单模块
- 项目优化
- 性能优化
- 使用缓存技术（如Redis）缓存热点数据，减少数据库访问次数。
- 对数据库进行优化，添加索引，优化SQL语句。
- 使用异步处理技术（如Spring的
@Async注解）处理耗时操作。
- 代码优化
- 提高代码的可读性和可维护性，遵循编码规范。
- 使用设计模式（如工厂模式、单例模式等）优化代码结构。
- 安全性优化
- 防止SQL注入攻击，使用参数化查询。
- 防止XSS攻击，对用户输入进行过滤和编码。
- 防止CSRF攻击，使用Token验证。
六、Java Web安全
（一）常见的Web安全问题
- SQL注入
- 攻击者通过在输入框中输入恶意SQL语句，篡改数据库查询语句，从而获取敏感信息或篡改数据库数据。
- 防范方法：
- 使用参数化查询（如PreparedStatement）。
- 对用户输入进行验证和过滤。
- XSS攻击（跨站脚本攻击）
- 攻击者通过在网页中插入恶意脚本，当其他用户访问该网页时，恶意脚本会执行，从而窃取用户信息或篡改网页内容。
- 防范方法：
- 对用户输入进行编码和转义，防止恶意脚本注入。
- 使用内容安全策略（CSP）限制外部脚本的加载。
- CSRF攻击（跨站请求伪造）
- 攻击者通过诱导用户点击恶意链接或提交恶意表单，利用用户的登录状态向目标网站发送伪造的请求，从而执行非法操作。
- 防范方法：
- 使用Token验证，确保请求的合法性。
- 对敏感操作进行二次验证（如验证码）。
（二）Java Web的安全防护
- 输入验证
- 输出编码
- 使用安全框架
- 使用Spring Security框架进行用户认证和授权。
- 示例：
@Configuration
@EnableWebSecurity
public class SecurityConfig extends WebSecurityConfigurerAdapter {@Overrideprotected void configure(HttpSecurity http) throws Exception {http.authorizeRequests().antMatchers("/admin/**").hasRole("ADMIN").antMatchers("/user/**").hasRole("USER").antMatchers("/", "/register", "/login").permitAll().anyRequest().authenticated().and().formLogin().loginPage("/login").defaultSuccessUrl("/home", true).permitAll().and().logout().permitAll();}
}
- 认证和授权
七、Java Web前沿技术
（一）前后端分离
- 前后端分离的概念
- 将前端页面和后端服务分离，前端使用HTML、CSS、JavaScript等技术开发，后端使用Java等技术开发。
- 前端通过调用后端提供的API接口获取数据。
- RESTful API的设计
- REST（Representational State Transfer）是一种软件架构风格，用于设计网络应用程序。
- RESTful API是基于HTTP协议的API，通过HTTP方法（GET、POST、PUT、DELETE等）操作资源。
- 示例：
- 获取用户信息
GET /api/users/{id}
- 创建用户
POST /api/users
- 更新用户
PUT /api/users/{id}
- 删除用户
DELETE /api/users/{id}
- 前端框架（Vue.js、React.js等）
（二）微服务架构
- 微服务的概念
- 微服务是一种架构风格，将复杂的应用程序分解为一组小型、独立的服务。
- 每个微服务都围绕特定的业务功能构建，可以独立部署和扩展。
- Spring Cloud
- 是一个基于Spring Boot实现的微服务框架，提供了服务注册与发现、配置中心、网关、熔断器等功能。
- 服务注册与发现
- 配置中心
- 网关
- 熔断器
- Docker
- 是一个开源的应用容器引擎，用于创建、部署和运行应用程序。
- 示例：
- 创建Dockerfile
FROM openjdk:11-jre-slim
COPY target/myapp.jar /app.jar
ENTRYPOINT ["java", "-jar", "/app.jar"]
- 构建镜像
docker build -t myapp:1.0 .
- 运行容器
docker run -d -p 8080:8080 myapp:1.0
（三）大数据与Java Web
- 大数据的概念
- 大数据是指数据量巨大、类型多样、处理速度快的数据集合。
- 常见的大数据技术栈包括Hadoop、Spark、HBase、Kafka等。
- Java Web与大数据的结合
- 数据采集
- 使用Java Web应用作为数据采集端，将用户数据发送到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");
KafkaProducer<String, String> producer = new KafkaProducer<>(props);
producer.send(new ProducerRecord<>("mytopic", "key", "value"));
producer.close();
- 数据分析
- 数据展示
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/905508.html
如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！
