• 网站首页
• 网站建设
• 短视频
• 网站推广
• 网站模板
• 客户案例
• 资讯动态
• 关于我们

tomcat可以做socket通信吗_java

当前位置：网站建设 > 技术支持

tomcat可以做socket通信吗？

可以在tomcat环境下用Java程序实现Socket通信，代码如下：

服务端：

/**

*

*/

package com.dnion.socket;

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import java.net.ServerSocket;

import java.net.Socket;

/**

***************************************************************

* 项目名称：JavaThread

* 程序名称：JabberServer

* 日期：2015-7-11 下午21:01:12

* 作者：Administrator

* @version

***************************************************************

*/

public class JabberServer {

public static int PORT = 8080;

public static void main(String[] agrs) {

ServerSocket s = null;

Socket socket = null;

BufferedReader br = null;

PrintWriter pw = null;

try {

//设定服务端的端口号

s = new ServerSocket(PORT);

System.out.println("ServerSocket Start:"+s);

//等待请求,此方法会一直阻塞,直到获得请求才往下走

socket = s.accept();

System.out.println("Connection accept socket:"+socket);

//用于接收客户端发来的请求

br = new BufferedReader(new InputStreamReader(socket.getInputStream()));

//用于发送返回信息,可以不需要装饰这么多io流使用缓冲流时发送数据要注意调用.flush()方法

pw = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);

while(true){

String str = br.readLine();

if(str.equals("END")){

break;

}

System.out.println("Client Socket Message:"+str);

Thread.sleep(1000);

pw.println("Message Received");

pw.flush();

}

} catch (Exception e) {

// TODO Auto-generated catch block

e.printStackTrace();

}finally{

System.out.println("close.....");

try {

br.close();

pw.close();

socket.close();

s.close();

} catch (Exception e2) {

}

}

}

}

客户端：

/**

*

*/

package com.dnion.socket;

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import java.net.Socket;

/**

***************************************************************

* 项目名称：JavaThread 程序名称：JabberClient

* 作者：Administrator

* @version

***************************************************************

*/

public class JabberClient {

/**

* 方法名：main

*

* @param @param args

* @return void

*/

public static void main(String[] args) {

Socket socket = null;

BufferedReader br = null;

PrintWriter pw = null;

try {

//客户端socket指定服务器的地址和端口号

socket = new Socket("127.0.0.1", JabberServer.PORT);

System.out.println("Socket=" + socket);

//同服务器原理一样

br = new BufferedReader(new InputStreamReader(

socket.getInputStream()));

pw = new PrintWriter(new BufferedWriter(new OutputStreamWriter(

socket.getOutputStream())));

for (int i = 0; i < 10; i++) {

pw.println("howdy " + i);

pw.flush();

String str = br.readLine();

System.out.println(str);

}

pw.println("END");

pw.flush();

} catch (Exception e) {

e.printStackTrace();

} finally {

try {

System.out.println("close......");

br.close();

pw.close();

socket.close();

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

}

}

版权说明：
本网站凡注明“广州京杭 原创”的皆为本站原创文章，如需转载请注明出处！
本网转载皆注明出处，遵循行业规范，如发现作品内容版权或其它问题的，请与我们联系处理！
欢迎扫描右侧微信二维码与我们联系。