本文主要是介绍【Java学习笔记】60：客户端PC-后端程序服务器-数据库服务器之间的通信demo，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
简述
经过不懈的努力，终于能把这三方的交互在不同电脑上实现了，学习完这个就可以着手做课程项目了。
客户端向后端程序服务器发送请求，由后端程序去查询另一台服务器上的数据库，将查询结果返回给客户端。
使用的数据库中的表是我的Java学习笔记55中最终的数据库表。
程序
基本按照课本上的例子敲，课本上有一处错误：服务器用来判断结果集是否为空的boolean值boo没有初始化为false。新学习了PreparedStatement类，相比Statement类创建的sql语句对象更好用。
客户端程序Client.java
import java.awt.BorderLayout;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.net.UnknownHostException;import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JOptionPane;
import javax.swing.JPanel;
import javax.swing.JTextArea;
import javax.swing.JTextField;//客户端程序
public class Client {public static void main(String[] args) {new QueryClient();}}// 客户端界面和线程写到一个类里
// 让连接服务器的线程对象被这个类组合,可以方便的使用其引用
// 监听器也使用这个类本身,使得各个控件的引用在监听器方法中可见
// 能够方便的对监听到的消息执行对控件的操作和对Socket的通信操作
class QueryClient extends JFrame implements Runnable, ActionListener {// 用到的组件JButton jb_cnnctn, jb_sndNmbr, jb_sndNm;JTextField jtf_inptNmbr, jtf_inptNm;JTextArea jta_rslt;// 客户端Socket对象Socket sckt = null;// 输入流,输出流DataInputStream dis = null;DataOutputStream dos = null;// 线程对象Thread thrd;// 构造器public QueryClient() {sckt = new Socket();// 无参构造,后面连接时再指定ip地址和端口号!JPanel jp = new JPanel();// 面板,组件放在面板上// 组件初始化jb_cnnctn = new JButton("连接服务器");jb_sndNmbr = new JButton("按学号查询");jb_sndNmbr.setEnabled(false);// 在成功连接到服务器之前不能查询jb_sndNm = new JButton("按姓名查询");jb_sndNm.setEnabled(false);// 同样先设置成不可用jtf_inptNmbr = new JTextField(8);// 8列jtf_inptNm = new JTextField(8);jta_rslt = new JTextArea(6, 42);// 6行42列// 嵌套给面板jp.add(jb_cnnctn);jp.add(new JLabel("输入学号:"));// 这种写文字的标签用匿名对象就行了jp.add(jtf_inptNmbr);jp.add(jb_sndNmbr);jp.add(new JLabel("输入姓名"));jp.add(jtf_inptNm);jp.add(jb_sndNm);// 嵌套给JFrame,方位布局this.add(jp, BorderLayout.NORTH);this.add(jta_rslt, BorderLayout.CENTER);// 为三个按钮注册监听器jb_cnnctn.addActionListener(this);jb_sndNm.addActionListener(this);jb_sndNmbr.addActionListener(this);// 新建线程thrd = new Thread(this);this.setBounds(10, 30, 700, 300);this.setVisible(true);this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);this.validate();}@Overridepublic void run() {String s = null;// 不停地尝试读入while (true) {try {// 从输入流读入查询结果s = this.dis.readUTF();// 子线程阻塞之处this.jta_rslt.append("[+]" + s + "\n");// 将读入的结果写入文本区域} catch (IOException e) {this.jta_rslt.append("[x]与服务器断开");break;// 断开后退出循环结束子线程}}}@Overridepublic void actionPerformed(ActionEvent e) {// 当要连接数据库时if (e.getSource() == this.jb_cnnctn) {// 只要Socket对象还没有连接(防止重复连接)if (!this.sckt.isConnected()) {try {// 网络地址对象InetAddress ina = InetAddress.getByName("192.168.0.108");// 网络地址组合端口的套接字对象InetSocketAddress insa = new InetSocketAddress(ina, 3838);// 尝试连接到服务器,可能发生阻塞this.sckt.connect(insa);// 用建立好连接的Socket对象初始化输入输出流,与服务器输入输出关联this.dis = new DataInputStream(this.sckt.getInputStream());this.dos = new DataOutputStream(this.sckt.getOutputStream());// 连接完全建立好后,可以允许查询了this.jb_sndNmbr.setEnabled(true);this.jb_sndNm.setEnabled(true);// 查询独立所在的线程开始工作this.thrd.start();} catch (UnknownHostException e1) {JOptionPane.showMessageDialog(this, "无法解析服务器域名");} catch (IOException e1) {JOptionPane.showMessageDialog(this, "无法连接到服务器");}}}// 当要按学号查询时else if (e.getSource() == this.jb_sndNmbr) {// 从输入学号的框中获取信息String s = this.jtf_inptNmbr.getText();// 检查非空if (s != null) {try {// 加上字符串头表示这是学号,并发送给服务器this.dos.writeUTF("number:" + s);} catch (IOException e1) {JOptionPane.showMessageDialog(this, "学号发送失败");}}}// 当要按姓名查询时else if (e.getSource() == this.jb_sndNm) {// 从输入姓名的框中获取信息String s = this.jtf_inptNm.getText();// 检查非空if (s != null) {try {// 加上字符串头表示这是姓名,并发送给服务器this.dos.writeUTF("name:" + s);} catch (IOException e1) {e1.printStackTrace();}}}}// end actionPerformed}后端程序Server.java
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;public class Server {public static void main(String[] args) {try {// JVM加载JDBC驱动Class.forName("com.mysql.jdbc.Driver");// sql连接对象java.sql.Connection con;// PreparedStatement是Statement的子类,也是一种sql语句对象java.sql.PreparedStatement ps1, ps2;// 结果集ResultSet rs;// 连接信息字符串,MySQL数据库服务器的默认端口号是3306// jdbc:mysql://ip地址:端口号/要连接的数据库名?其它选项// useSSL参数指明数据通道是否要加密处理// characterEncoding参数指明连接编码,要和数据库编码,数据库表的编码,数据库系统的编码一致String uri = "jdbc:mysql://192.168.0.106:3306/newDB?useSSL=true&characterEncoding=utf8";String user = "root";// 用户名String password = "3838438"; // 密码// 和指定的数据库建立连接(连接信息字符串,用户名,密码)con = DriverManager.getConnection(uri, user, password);// 使用PreparedStatement时,其构造方法中直接传入要执行的sql语句,暂时不确定的地方使用问号// 所以execute(),executeQuery()和executeUpdate()不再需要参数ps1 = con.prepareStatement("SELECT * FROM NewUsr WHERE id=?");ps2 = con.prepareStatement("SELECT * FROM NewUsr WHERE name=?");ServerSocket ss = null;// 服务端Socket,用来建立Socket对象Thread thrd = null;// (子)线程对象Socket sckt = null;// Socket连接对象// 不听地监听用户的连接请求while (true) {try {ss = new ServerSocket(3838);// 3838端口System.out.println("等待客户端连接...");sckt = ss.accept();// 阻塞以等待连接System.out.println("[+]客户端地址:" + sckt.getInetAddress());// 对象上转型,为这个新客户建立(子)线程对象thrd = new Target(sckt, ps1, ps2);// 将Socket连接对象和两个准备好的sql语句对象的引用传入// 启动专为这个客户服务的这个线程thrd.start();} catch (IOException e) {// 不能重复创建ServerSocket}}} catch (ClassNotFoundException e) {e.printStackTrace();} catch (SQLException e) {e.printStackTrace();}}}// 线程类,每个客户单独一个线程,继承Thread类方便一些
// 这个线程做两个方面的工作:1.查询数据库,2:和用户做信息的交互(输入输出)
class Target extends Thread {// 从构造器传入的Socket连接对象和两个sql语句对象Socket sckt;PreparedStatement ps1, ps2;// 数据输入输出流DataInputStream dis;DataOutputStream dos;// boo用来在遍历结果集时记录结果集是否为空,从而特判查询结果为空的情况boolean boo = false;// 构造器public Target(Socket sckt, PreparedStatement ps1, PreparedStatement ps2) {this.sckt = sckt;this.ps1 = ps1;this.ps2 = ps2;try {// 用Socket连接对象去初始化输入输出流,将其与客户端输出输入连接this.dis = new DataInputStream(sckt.getInputStream());this.dos = new DataOutputStream(sckt.getOutputStream());} catch (IOException e) {e.printStackTrace();}}@Overridepublic void run() {ResultSet rs = null;// 查询返回的结果集// 不停地和用户交互while (true) {this.boo = false;// 表示结果集是否为空的布尔量,每次交互前置为falsetry {String str = dis.readUTF();// 从输入流读入用户发来的消息// 判断其消息格式,如果以"number:"开头,表示按学号查询if (str.startsWith("number:")) {// 剪切掉信息类型头,从第一次出现":"的位置向后1字符开始直到结尾str = str.substring(str.indexOf(":") + 1);// PreparedStatement对象的setString方法定义了字符串中第n个"?"字符的替换ps1.setString(1, str);// 返回结果集,注意PreparedStatement对象的执行方法不需要参数// 因为sql语句就在PreparedStatement对象中rs = ps1.executeQuery();}// 按姓名查询if (str.startsWith("name:")) {// 剪切掉信息类型头,从第一次出现":"的位置向后1字符开始直到结尾str = str.substring(str.indexOf(":") + 1);// PreparedStatement对象的setString方法定义了字符串中第n个"?"字符的替换ps2.setString(1, str);// 返回结果集,注意PreparedStatement对象的执行方法不需要参数// 因为sql语句就在PreparedStatement对象中rs = ps2.executeQuery();}// 对返回的结果集的处理while (rs.next() == true) {boo = true;// 非空int id = rs.getInt(1);// 获取这行的idString name = rs.getString(2);// 这行的nameint age = rs.getInt(3);// 这行的age// 拼成字符串,发送给客户端this.dos.writeUTF("[v]学号:" + id + " 姓名:" + name + " 年龄" + age);}// 结果集为空,表示没有这个学生if (boo == false)this.dos.writeUTF("[x]没有此学生");} catch (IOException e) {System.out.println("[-]客户端" + sckt.getInetAddress() + "断开连接");return;// 结束这个线程,因为这个线程就是为这个客户服务的} catch (SQLException e) {e.printStackTrace();}}}}运行结果
客户端运行结果
后端程序服务器输出
等待客户端连接...
[+]客户端地址:/192.168.0.106
等待客户端连接...
[-]客户端/192.168.0.106断开连接这篇关于【Java学习笔记】60：客户端PC-后端程序服务器-数据库服务器之间的通信demo的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
