Commit 0230aed5 by admin

修改服务端

parent 07b8a5c8
...@@ -8,7 +8,6 @@ import java.util.List; ...@@ -8,7 +8,6 @@ import java.util.List;
import org.apache.commons.logging.Log; import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory; import org.apache.commons.logging.LogFactory;
import org.bson.Document; import org.bson.Document;
import org.springframework.stereotype.Component;
import com.zhiwei.util.Config; import com.zhiwei.util.Config;
import com.zhiwei.util.ExcelUtil; import com.zhiwei.util.ExcelUtil;
...@@ -18,7 +17,7 @@ import com.zw.entity.NewsResult; ...@@ -18,7 +17,7 @@ import com.zw.entity.NewsResult;
import sendmail.SendMailUtil; import sendmail.SendMailUtil;
@Component //@Component
public class PushFinanceByTime extends Thread { public class PushFinanceByTime extends Thread {
private static final Log log = LogFactory.getLog(PushFinanceByTime.class); private static final Log log = LogFactory.getLog(PushFinanceByTime.class);
......
...@@ -28,6 +28,7 @@ public class ServerClient extends Thread { ...@@ -28,6 +28,7 @@ public class ServerClient extends Thread {
try { try {
server = new ServerSocket(22222); server = new ServerSocket(22222);
System.out.println("服务启动"); System.out.println("服务启动");
while (true) {
Socket socket = server.accept(); Socket socket = server.accept();
String line = ""; String line = "";
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream())); BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
...@@ -37,7 +38,6 @@ public class ServerClient extends Thread { ...@@ -37,7 +38,6 @@ public class ServerClient extends Thread {
line = in.readLine(); line = in.readLine();
System.out.println(line); System.out.println(line);
// line = br.readLine(); // line = br.readLine();
while (true) {
if (line != null && line.equals("result")) { if (line != null && line.equals("result")) {
writer.println("result:end"); writer.println("result:end");
writer.flush(); writer.flush();
...@@ -60,10 +60,10 @@ public class ServerClient extends Thread { ...@@ -60,10 +60,10 @@ public class ServerClient extends Thread {
if (line != null && line.equals("asdasd")) { if (line != null && line.equals("asdasd")) {
break; break;
} }
}
writer.close(); writer.close();
in.close(); in.close();
socket.close(); // socket.close();
}
server.close(); server.close();
} catch (IOException e) { } catch (IOException e) {
e.printStackTrace(); e.printStackTrace();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment