一个简单的java web程序（servlet实现接口）

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
package com.musicRec.Code;

import com.musicRec.Utils.MusicRec;

import java.util.Map;

/**
 * Created by Administrator on 2017/6/11.
 */
public class MusicRecThread implements Runnable{

    private String userId;

    public MusicRecThread(String userId){
        this.userId = userId;
        System.out.println("start thread...");
    }

    public void run(){

        if(MusicRec.downLoadFiles(userId)){
            //执行推荐算法
            Map<String,Object> result = MusicRec.excuteMusicRec(userId);
            if(result.get("success").equals(false)){
                result.put("msg","推荐算法执行出错");
            }
        };

    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
package com.musicRec.Servlet;

import com.alibaba.fastjson.JSON;
import com.musicRec.Code.MusicRecThread;

import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.io.PrintWriter;
import java.util.HashMap;
import java.util.Map;

/**
 * Created by Administrator on 2017/6/10.
 */
//@WebServlet("/getRecResult")
public class ExecuteRec extends HttpServlet {

    @Override
    public void init() throws ServletException {
    }

    @Override
    protected void service(HttpServletRequest request, HttpServletResponse response)
            throws ServletException, IOException {

        Map<String,Object> result = new HashMap<>();

        // 获取用户的name
        String userId = request.getParameter("userId");
        String jsonString = "";
// 设置输出
        response.setContentType("text/html;charset=GBK");
        PrintWriter printWriter = response.getWriter();
        // 对name进行转码
        if (userId != null) {
            userId = new String(userId.getBytes("ISO-8859-1"), "GBK");
            System.out.println("userId=" + userId);
            Thread t = new Thread(new MusicRecThread(userId));
            t.start();
            System.out.println("thread starting...");
            result.put("success",true);
        } else {
            result.put("success",false);
            result.put("msg","没有传入userId");
        }
        jsonString = JSON.toJSONString(result);
        printWriter.println(jsonString);
        printWriter.close();
    }

    @Override
    public void destroy() {
        super.destroy();
    }

}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
package com.musicRec.Utils;

import ch.ethz.ssh2.Connection;
import ch.ethz.ssh2.Session;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.musicRec.Entity.RecordInfo;

import java.io.IOException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Objects;

/**
 * Created by Administrator on 2017/6/10.
 */
public class MusicRec {

    private static String url = "";
    private static String charset = "utf-8";
    private static HttpClientUtil httpClientUtil = new HttpClientUtil();;
    //ftp服务器
    private static String FTPHOSTNAME = "";
    private static String FTPNAME = "";
    private static String FTPPASSWORD = "";
    private static String REMOTEPATH = "";
    private static String LOCALPATH = "/home/ubuntu/Desktop/music_rec/user_sim/audio";
    //算法服务器
    private static String HOSTNAME = "";
    private static String NAME = "";
    private static String PASSWORD = "";
    //TODO:生成推荐信息文件
    private static String TARGETFILEPATH = "/home/ubuntu/Desktop/music_rec/user_sim/result/xyy_result_m10d2.json";

    /**
     * 根据post回来的信息下载文件到算法服务器上
     * @param userId
     * @return
     */
    public static boolean downLoadFiles(String userId){

        String httpOrgCreateTest = url + "hmzmysql/cors/getRecordInfo";
        Map<String,String> createMap = new HashMap<>();
        createMap.put("userId",userId);
        String httpOrgCreateTestRtn = httpClientUtil.doPost(httpOrgCreateTest,createMap,charset);
        System.out.println("result:" + httpOrgCreateTestRtn);

        JSONObject jsonObj = JSON.parseObject(httpOrgCreateTestRtn);

        JSONArray recordInfoArray = jsonObj.getJSONArray("recordInfo");

        List<RecordInfo> recordInfo = JSON.parseArray(recordInfoArray.toJSONString(), RecordInfo.class);

        for (RecordInfo r:recordInfo){
            System.out.println(r.getIsFlag());
            System.out.println(r.getUrl());
//            System.out.println();
//            System.out.println();
        }

//        Boolean flag = FtpClientUtils.downFile(FTPHOSTNAME,21,FTPNAME,FTPPASSWORD,REMOTEPATH,fileName,LOCALPATH);
//        return flag;
        return true;
    }


    /**
     * 执行推荐算法
     * @param userId
     * @return
     */
    public static Map<String,Object> excuteMusicRec(String userId){
        Map<String,Object> map = new HashMap<>();
        try {
        Connection conn = new Connection(HOSTNAME);
        conn.connect();//连接
        Boolean flg = conn.authenticateWithPassword(NAME, PASSWORD);//认证
        if (flg) {
            System.out.println("=====第一个步骤=====");
            Session session = conn.openSession();//打开一个会话
            //TODO:多条命令
            session.execCommand("cd /home/ubuntu/Desktop/music_rec/user_sim;echo "123" | sudo  -S ./caculate_tim_sim.sh similar");//执行命令
            String result = RemoteExecuteCommand.processStdout(session.getStdout(), charset);
            //如果为得到标准输出为空，说明脚本执行出错了
            if ("".equals(result)) {
                System.out.println("脚本出错");
                result = RemoteExecuteCommand.processStdout(session.getStderr(), charset);
            }
            System.out.println(result);
            session.close();

//            System.out.println("=====第二个步骤=====");
//            Session session2 = conn.openSession();//打开一个会话
//            //TODO:多条命令
//            session2.execCommand("cd /home/ubuntu/Desktop/music_rec/user_sim/result;cat xyy_result_m10d.json");//执行命令
//            String result2 = RemoteExecuteCommand.processStdout(session2.getStdout(), charset);
//            //如果为得到标准输出为空，说明脚本执行出错了
//            if ("".equals(result2)) {
//                System.out.println("脚本出错");
//                result2 = RemoteExecuteCommand.processStdout(session2.getStderr(), charset);
//            }
//            System.out.println(result2);
//            map.put("jsonData",result2);
//            session2.close();

            System.out.println("=====第三个步骤=====");
            Session session3 = conn.openSession();//打开一个会话
            //TODO:多条命令
            session3.execCommand("cd /home/ubuntu/Desktop/music_rec/effective_range_of_singing_voice;python batch.py");//执行命令
//                session2.execCommand("cd /home/ubuntu/Desktop/music_rec/user_sim/result;ls");//执行命令
            String result3 = RemoteExecuteCommand.processStdout(session3.getStdout(), charset);
            //如果为得到标准输出为空，说明脚本执行出错了
            if ("".equals(result3)) {
                System.out.println("脚本出错");
                result3 = RemoteExecuteCommand.processStdout(session3.getStderr(), charset);
            }
            System.out.println(result3);
            session3.close();

            System.out.println("=====第四个步骤(生成推荐结果)=====");
            Session session4 = conn.openSession();//打开一个会话
            //TODO:多条命令
            session4.execCommand("cd /home/ubuntu/Desktop/music_rec/recommendation;python recomendation.py");//执行命令
            String result4 = RemoteExecuteCommand.processStdout(session4.getStdout() , charset);
            //如果为得到标准输出为空，说明脚本执行出错了
            if ("".equals(result4)) {
                System.out.println("脚本出错");
                result4 = RemoteExecuteCommand.processStdout(session4.getStderr(), charset);
            }
            System.out.println(result4);
//            map.put("recResult", result4);
            session4.close();

            conn.close();
            map.put("success",true);
        }else {
            System.err.println("连接失败！");
            map.put("success",false);
        }
        } catch (IOException e) {
            e.printStackTrace();
        }
        return map;
    }


    /**
     * 得到推荐结果
     * @param userId
     * @return
     */
    public static Map<String,Object> getMusicRecResult(String userId){
        Map<String,Object> resultMap = new HashMap<>();
        try {
            Connection conn = new Connection(HOSTNAME);
            conn.connect();//连接
            Boolean flg = conn.authenticateWithPassword(NAME, PASSWORD);//认证
            if (flg) {

                System.out.println("=====1.得到Json=====");
                Session session = conn.openSession();//打开一个会话
                //TODO:多条命令
                session.execCommand("cd /home/ubuntu/Desktop/music_rec/user_sim/result;cat xyy_result_m10d.json");//执行命令
                String result = RemoteExecuteCommand.processStdout(session.getStdout(), charset);
                //如果为得到标准输出为空，说明脚本执行出错了
                if ("".equals(result)) {
                    System.out.println("脚本出错");
                    result = RemoteExecuteCommand.processStdout(session.getStderr(), charset);
                }
                System.out.println(result);
                resultMap.put("jsonData",result.replace("n",""));
                session.close();

                System.out.println("=====2.得到推荐结果=====");
                Session session2 = conn.openSession();//打开一个会话
                //TODO:多条命令
                session2.execCommand("cd /home/ubuntu/Desktop/music_rec/user_sim/result;cat sorted_result.txt");//执行命令
                String result2 = RemoteExecuteCommand.processStdout(session2.getStdout(), charset);
                //如果为得到标准输出为空，说明脚本执行出错了
                if ("".equals(result2)) {
                    System.out.println("脚本出错");
                    result2 = RemoteExecuteCommand.processStdout(session2.getStderr(), charset);
                }
                System.out.println(result2);
                resultMap.put("recResult", result2.replace("t","_").replace("n",","));
                session2.close();

                conn.close();
                resultMap.put("success",true);
            }else {
                System.err.println("连接失败！");
                resultMap.put("success",false);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }


        return resultMap;
    }




    public static void main(String[] args) {

    }


}