转载自：http://blog.csdn.net/gulu_gulu_jp/article/details/50994003
 
 
 一、前言
 
 
 前面我们已经尝过了在云服务器上部署代码的甜头了，现在主菜就要上场了，那就是将我们的 JavaWeb 项目部署到云服务器上。兴奋吧？淡定淡定~
 
 二、项目部署
 
 我们对于 Java Web 项目在本地机器(无论是 Windows 还是 Linux)上的部署已经了然于心了，那么对于在云服务器上部署 Java Web 项目又是如何操作的呢？ 其实很简单，还是离不开 Web 项目部署的那三点： 
 ① 基础的 JDK 环境 
 ② 一个 Web 服务器。如 Tomcat、JBoss 
 ③ 一款数据库。如：mysql
 
 对于云服务器上 Java Web 项目的部署，和平时在 Windows、Linux 下部署是一样的。最多也就是只能使用纯命令模式来操作而已，其实过程都一样。
 
 2.1 环境准备
 
 既然是 Java Web 项目的部署，首先自然需要配置好相关的环境罗。也就是：先在云主机上搭建好 Java 开发环境，如 OpenJDK 的安装、Tomcat 的安装、Mysql 数据库的安装。 
 注：关于这些软件的安装就不再该篇文章中叙述了，我会在另外的2篇文章中详细阐述的。
 
 
 
 OpenJDK 和 Tomcat 的安装，请阅读：Java笔记—CenOS下配置Java开发环境（OpenJDK + Tomcat8）
 Mysql 的安装，请阅读：Java笔记—CenOS下配置Mysql
 
 
 2.2 项目部署
 
 我们要部署 Java Web 项目，那就至少得将项目上传到云服务器。其实过程很简单，基本上也就是下面三个步骤： 
 ① 打包上传：将项目打包成 war 文件，然后利用 FileZilla 传到远程服务器 
 ② 部署：使用 cp 或 mv 命令，将 war 文件移动到 Tomcat 目录下的 webapps 下 
 ③ 重启 Tomcat，访问我们的项目
 
 在这个过程中，我们需要注意。因为一般而已，作为一个 Web 项目，我们肯定是有数据库的使用的。那么数据库部分怎么办呢？其实，只需要将我们已有的数据库转储为 sql 文件，然后将 sql 文件上传到云服务器上执行即可。以 mysql 为例，如下操作：
 
 
 
 Mysql 案例
 
 
① 转储为 sql 脚本，并上传：先在本地将我们项目使用的数据库转为 sql 文件，上传到云服务器上 
 
① 转储为 sql 脚本，并上传：先在本地将我们项目使用的数据库转为 sql 文件，上传到云服务器上 
  
 ② 执行 sql：然后进入 mysql 中执行该 sql 文件 
 
 
 

 
 
 
 发现执行的时候有错。原因是我们此时的 mysql 中没有 thinkphp 这个数据库。我们查看下当前的数据库，执行命令 show databases; 
 
 
 发现确实没有 thinkphp 这个数据库，因此我们创建一个，执行命令 create database thinkphp; 
  
 
 再次执行 
 
 
 发现还是报错。原因是我们当前使用的是 mysql 这个数据库，而不是 thinkphp 数据库。因此我们切换到 thinkphp 数据库，执行命令 use thinkphp;，然后再一次执行 sql 文件： 
  
 
③ 查看结果 

 

 

 
先不管显示的是乱码(因为刚才查看该 sql 文件就知道会是这个结果了)，可以看到确实已经弄好了 

 
④ 
部署项目
：将项目部署到 Tomcat 容器中，还是使用 cp 或 mv 命令将 war 文件移到 /usr/local/tomcat8/webapps/ 下，重启 Tomcat，再访问 

 


 

 
 
 
 可以看到成功了对吧？其实不然，因为我们发现，需要使用数据库获取数据的部分却没有数据，这是为啥呢？错误的原因可能有以下几个： 
 ① 项目中使用的是 mysql5.1.10 的驱动 jar，而云服务器默认的是使用 mysql5.1.73 因此，要么重装一个 mysql，要么将项目中的驱动改为 mysql5.1.73。 
 ② 未将 mysql 驱动jar 放入 jvm/java-1.8.0xxx/jre/lib/ext/ 下 
 ③ 密码不正确 
 ④ 使用的是 root 账户，而 root 账户在 Linux 下访问 mysql 是不需要使用密码的
 
 通过排查，发现是因为项目中是使用 root 账户的，因此我们在本地中将项目代码关于数据库连接部分改一下，将密码置空串，再次部署，就可以恢复正常了，看看结果吧！ 
 
 

 
成功显示，连上了 mysql！
 
 

 
 

 

步骤一：添加依赖
 
        <!--sftp文件上传-->
        <dependency>
            <groupId>com.jcraft</groupId>
            <artifactId>jsch</artifactId>
            <version>0.1.54</version>
        </dependency>
 
步骤二：编写工具类
 
package com.example.vue.vuedemo;


import com.jcraft.jsch.Channel;
import com.jcraft.jsch.*;

import java.io.*;

/**
 * Created by jlm on 2019-09-17 17:44
 */
public class FtpUtils {

    /**
     * 利用JSch包实现SFTP上传文件
     * @param bytes  文件字节流
     * @param fileName  文件名
     * @throws Exception
     */
    public static void sshSftp(byte[] bytes,String fileName) throws Exception{
        //指定的服务器地址
        String ip = "服务器ip地址";
        //用户名
        String user = "用户名";
        //密码
        String password = "密码";
        //服务器端口 默认22
        int port = 22;
        //上传文件到指定服务器的指定目录 自行修改
        String path = "/root";

        Session session = null;
        Channel channel = null;


        JSch jsch = new JSch();


        if(port <=0){
            //连接服务器，采用默认端口
            session = jsch.getSession(user, ip);
        }else{
            //采用指定的端口连接服务器
            session = jsch.getSession(user, ip ,port);
        }

        //如果服务器连接不上，则抛出异常
        if (session == null) {
            throw new Exception("session is null");
        }

        //设置登陆主机的密码
        session.setPassword(password);//设置密码
        //设置第一次登陆的时候提示，可选值：(ask | yes | no)
        session.setConfig("StrictHostKeyChecking", "no");
        //设置登陆超时时间
        session.connect(30000);


        OutputStream outstream = null;
        try {
            //创建sftp通信通道
            channel = (Channel) session.openChannel("sftp");
            channel.connect(1000);
            ChannelSftp sftp = (ChannelSftp) channel;


            //进入服务器指定的文件夹
            sftp.cd(path);

            //列出服务器指定的文件列表
//            Vector v = sftp.ls("*");
//            for(int i=0;i<v.size();i++){
//                System.out.println(v.get(i));
//            }

            //以下代码实现从本地上传一个文件到服务器，如果要实现下载，对换以下流就可以了
            outstream = sftp.put(fileName);
            outstream.write(bytes);

        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            //关流操作
            if(outstream != null){
                outstream.flush();
                outstream.close();
            }
            if(session != null){
                session.disconnect();
            }
            if(channel != null){
                channel.disconnect();
            }
        }
    }

}
 
步骤三：写一个接口上传文件，调用工具类方法即可
 
package com.example.vue.vuedemo;

import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;

import javax.servlet.http.HttpServletRequest;

/**
 * Created by jlm on 2019-09-17 17:42
 */
@RestController
public class UploadController {


    @RequestMapping("file")
    public void upload(HttpServletRequest httpServletRequest, MultipartFile file) throws Exception {
        byte[] bytes = file.getBytes();
        FtpUtils.sshSftp(bytes,"1111.jpg");

    }

}
 
 

简单快捷，亲测有效
 这种方法可以有效避免这个报错：Could not parse response code.Server Reply: SSH-2.0-OpenSSH_5.3
 先附截图：
 本地文件：
 
 上传后的远程文件：
 
 **
 
代码
 
**
 前端:采用了批量上传的模式
 
<form action="http://localhost:8787/fms-base-service/dc/moreFileUpload" method="post" name="f_upload" enctype="multipart/form-data">
						<input type="text" name="username" /><br>
						<input type="file" name="filename" multiple="multiple" /><br>
						<input type="submit" value="上传" />
</form>
 
后台controller:
 
    @RequestMapping("/dc/moreFileUpload")
    public ResultVo testUpload(MultipartHttpServletRequest request) throws Exception {
        Iterator<String> fileNames = request.getFileNames();
          while (fileNames.hasNext()) {
           //把fileNames集合中的值打出来
           String fileName=fileNames.next();
           List<MultipartFile> fileList=request.getFiles(fileName);
           if (fileList.size()>0) {
            //遍历文件列表
            Iterator<MultipartFile> fileIte=fileList.iterator();
            while (fileIte.hasNext()) {
             //获得每一个文件
             MultipartFile file =fileIte.next();
                /*上传*/
                String filePath = ""; //映射的地址
                InputStream input = file.getInputStream();
                String oldName = file.getOriginalFilename();//获取file图片名称
                String newName = IdUtils.genImageName();
                boolean result = FtpUtil.uploadFile("xxxxx", 22, "root", "xx", "/root/file", filePath, newName, input);

            }
           }
          }
        return ResultMsgHandler.generateSucessMsg(localeMessageSourceService.getMessage(BaseConstants.SAVE_SUCCESS), request);
 }  
 
工具类：
 
package com.sinotrans.fms.nvocc.utils;


import com.jcraft.jsch.Channel;
import com.jcraft.jsch.ChannelSftp;
import com.jcraft.jsch.JSch;
import com.jcraft.jsch.Session;
import org.apache.commons.net.ftp.*;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.SocketException;
import java.util.Properties;

public class FtpU {
    private static ChannelSftp sftp = null;


    /**
     * Description: 向FTP服务器上传文件
     * @param host FTP服务器ip
     * @param port FTP服务器端口
     * @param username FTP登录账号
     * @param password FTP登录密码
     * @param basePath FTP服务器基础目录,/home/ftpuser/images
     * @param filePath FTP服务器文件存放路径。例如分日期存放：/2018/05/28。文件的路径为basePath+filePath
     * @param filename 上传到FTP服务器上的文件名
     * @param input 输入流
     * @return 成功返回true，否则返回false
     */
    public static boolean uploadFile(String host, int port, String username, String password, String basePath,
                                     String filePath, String filename, InputStream input) {
        boolean result = false;
        FTPClient ftp = new FTPClient();
        File file=null;
        try {
            JSch jsch = new JSch();
            //获取sshSession  账号-ip-端口
            Session sshSession = jsch.getSession(username, host, port);
            //添加密码
            sshSession.setPassword(password);
            Properties sshConfig = new Properties();
            //严格主机密钥检查
            sshConfig.put("StrictHostKeyChecking", "no");
            sshSession.setConfig(sshConfig);
            //开启sshSession链接
            sshSession.connect();
            //获取sftp通道
            Channel channel = sshSession.openChannel("sftp");
            //开启
            channel.connect();
            sftp = (ChannelSftp) channel;
            file=new File(basePath);
            //设置为被动模式
            ftp.enterLocalPassiveMode();
            //设置上传文件的类型为二进制类型
            //进入到要上传的目录  然后上传文件
            sftp.cd(basePath);
            sftp.put(input,filename);
            input.close();
            result = true;
        } catch (IOException e) {
            e.printStackTrace();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (ftp.isConnected()) {
                try {
                    ftp.disconnect();
                } catch (IOException ioe) {
                }
            }
        }
        return result;
    }
}



 
生成UUID的工具类：
 
public class IdUtils {

    public static String genImageName() {
        String uuid = UUID.randomUUID().toString().trim();
        return uuid;
    }

    public static void main(String[] args) {
        String s = genImageName();
        System.out.println(s);

    }

}
 
关于文件上传后临时目录清空的问题详见：https://www.cnblogs.com/756623607-zhang/p/9721761.html

 
文章目录
 
前言
一，建立工程
二，导入jar包
三，编写DataBase类实现连接数据库与操作数据库
四，效果图
参考文章
 

 
前言
 
 
 
经过前面的环境部署，今天我们终于可以来连接数据库了。参考我之前的文章。这篇文章把前面两章连接起来，做一个小总结，并做一个可以保存用户登录数据的网站，代码主要解释对数据库的部分。
 
 
先前的开发环境安装：
 centos7从零搭建java web服务器
 MySQL从零安装配置
 
一，建立工程
 
1，在eclipse新建动态web工程，具体过程已经有很多人写过了，我就简单说明一下。
 
 
 
打开eclipse->file->new->dynamic web subject
 
 
tomcat版本选你安装的版本，方便以后调试，web module 版本我用2.5，跟3.0差不多。3.0少了web.xml的配置文件等。一路next下去就行了
 
 
二，导入jar包
 
 
 
连接MySQL需要导入MySQL相关的jar包，另外我还加入log包，对于开发非常有帮助，可以在控制台打印数据，方便debug。jar包就放下图示目录，另外还需要在项目右击->properties->java built path->libraries里添加我们刚刚添加的jar包，这样jar包才算真正导入；
 
 
jar包下载连接：
 链接: https://pan.baidu.com/s/143RT1qygtKIimCRmLdpAbw 提取码: vd22
 

 点击add jars 选择刚刚加入的jar包添加进去就行了
 
 *
 
三，编写DataBase类实现连接数据库与操作数据库
 
 
 
以下代码需要自己先了解SQL语句，MySQL基本命令。代码实现了连接数据库，对数据库的某表格进行添加，读取，更新操作。对应的应用是添加用户，读取用户登录信息，更新密码。
 
 
注意数据保存到MySQL数据库出现中文乱码的问题，要在前端，后台，连接串，MySQL都设置相同的编码方式，比如我选择的是utf8
 在MySQL命令中输入show variables like “%char%”;查看当前的编码，如图，都是utf8就没问题，需要修改的话可以查看修改办法
 
 
DataBase.java代码，主要实现对数据库连接和增改查操作
 
package myapp;

import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import com.mysql.jdbc.Connection;

public class DataBase {
	private static String driver="com.mysql.jdbc.Driver";//MySQL驱动
	private static String user = "prx";// MySQL的用户名和密码
    private static String password = "5812870-Prx";
    private static String ip_adress = "192.168.x.x";//主机ip地址
    /*
     * 说明：与数据库建立连接
     * 参数：数据库名称
     */
    private static Connection getConn(String DatabaseName) throws SQLException
    {
    	//设置MySQL的连接串编码为UTF-8，避免中文乱码问题
    	String url="jdbc:mysql://localhost:3306/"+DatabaseName+"?characterEncoding=UTF-8";
    	System.out.println("the url is :"+url);
    	Connection connection=null;
    	try {
			Class.forName(driver);//加载MySQL驱动程序
			//连接数据库 驱动+ip地址+端口号+用户名+密码，端口号默认是3306
			connection=(Connection) DriverManager.getConnection("jdbc:mysql://" + ip_adress + ":3306/" + DatabaseName,
                    user, password);
			connection.setEncoding("UTF-8");
			
		} catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
    	//返回connection对象
		return connection;
	}
    /*
     * 添加新用户
     * String name,String sex,string age,String id,String password,String emailadress
     */
    public static void adduser(String name,String sex,String age,String id,String password,String emailadress) throws SQLException
    {
    	String Database="myapp";
    	String sql="INSERT INTO myapp_user (name,sex,age,id,password,emailadress) VALUES (?,?,?,?,?,?)";
    	Connection connection=getConn(Database);
    	if (connection!=null){
            try {
                PreparedStatement ps=connection.prepareStatement(sql);
                if (ps!=null){
                	
                    ps.setString(1,name);
                    ps.setString(2,sex);
                    ps.setString(3,age);
                    ps.setString(4,id);
                    ps.setString(5,password);
                    ps.setString(6,emailadress);
                    //执行语句,注意！！！如果你的SQL 语句是诸如update,insert的更新语句，应该用statement的execute()方法
                    // select用的是statement的executeQuery()
                    ps.execute();
                    
                    connection.close();
                    ps.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
                
            }
        }
    }
    
    public static void updatepassword(String id,String newpassword) throws SQLException
    {
    	String Database="myapp";
    	String sql="UPDATE myapp_user SET password=? where id=?";
    	Connection connection=getConn(Database);
    	if (connection!=null){
            try {
                PreparedStatement ps=connection.prepareStatement(sql);
                if (ps!=null){
                    ps.setString(1,newpassword);
                    ps.setString(2,id);
                  
                    //执行语句,注意！！！如果你的SQL 语句是诸如update,insert的更新语句，应该用statement的execute()方法
                    // select用的是statement的executeQuery()
                    ps.execute();
                    
                    connection.close();
                    ps.close();
                	}
            } catch (SQLException e) {
                e.printStackTrace();
                
            }
    
    	}
    }
    /*
     * 读取指定的值
     * 输入id 键
     */
    public static String sele_userinfo(String id,String key) throws SQLException {
    	String value = null;
    	String Database="myapp";
    	String sql="SELECT "+key+" FROM myapp_user WHERE id=?";
    	
    	Connection connection=getConn(Database);
    	if (connection!=null){
            try {
                PreparedStatement ps=connection.prepareStatement(sql);
                if (ps!=null){
                    ps.setString(1,id);
                    ResultSet rs=ps.executeQuery();
                    if(rs!=null) {
                    	int count =rs.getMetaData().getColumnCount();
                        while   (rs.next()){
                            for (int i=1 ;i<=count;i++){
                                String field=rs.getMetaData().getColumnName(i);     
                                    value=rs.getString(field);
                                    System.out.println("the database value is:"+value); 
                            	}
                        }
                    
                	}
                }
            } catch (SQLException e) {
                e.printStackTrace();
                
            }
    
    	}
    	return value;
    }
    /*
     * 检查id'是否存在
     * 传入id
     */
    public static int hasId(String id) throws SQLException {
    	String Database="myapp";
    	String value;
    	String sql="select id from myapp_user";
    	 System.out.println("the input id is :"+id);
    	Connection connection=getConn(Database);
    	if (connection!=null){
            try {
                PreparedStatement ps=connection.prepareStatement(sql);
                if (ps!=null){
                   
                    ResultSet rs=ps.executeQuery();
                    if(rs!=null) {
                    	int count =rs.getMetaData().getColumnCount();
                        while   (rs.next()){
                            for (int i=1 ;i<=count;i++){
                                String field=rs.getMetaData().getColumnName(i);     
                                value=rs.getString(field);
                                
                                System.out.println("the database id is:"+value); 
                        
                                if(value.equals(id))
                                {                            
                                	return 1;
                                }
                                	 
                            	}
                        }
                    
                	}
                }
            } catch (SQLException e) {
                e.printStackTrace();               
            }   
    	}
    	return 0;
    }
}
 
四，效果图
 
登录页面
 
 注册
 
 
 在终端查看数据库，数据保存成功
 
 登录成功！
 
 整个工程文件下载：
 链接: https://pan.baidu.com/s/1jq4LoetVdoksjjjGQeb4MA 提取码: 33xw 复制这段内容后打开百度网盘手机App，操作更方便哦
 2020.3.16
 
参考文章
 
Eclipse创建java Web项目工程