socket通信(一)
2016-01-15 16:42
225 查看
java socket通信已经被封装好了主要使用两个类ServerSocket 和Socket
首先写一个1v1的通信
服务端
[java] view
plaincopy
/**
*
*/
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
* 日期:2012-8-23 上午11:36:12
* 作者:
* 模块:
* 描述:
* 备注:
* ------------------------------------------------------------
* 修改历史
* 序号 日期 修改人 修改原因
*
* 修改备注:
* @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) {
}
}
}
}
客户端
[java] view
plaincopy
/**
*
*/
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 日期:2012-8-23 下午01:47:12
* 作者:
* 模块:
* 描述:
* 备注:
* ------------------------------------------------------------
* 修改历史
* 序号
* 日期
* 修改人
* 修改原因
* 修改备注:
*
* @version
***************************************************************
*/
public class JabberClient {
/**
* 方法名:main 描述: 作者:白鹏飞 日期:2012-8-23 下午01:47:12
*
* @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();
}
}
}
}
这样一个简单地通信就完成了,这里我们要注意现在只能一对一通信。下面我们将使用多线程来实现多客户端通信的例子。
首先写一个1v1的通信
服务端
[java] view
plaincopy
/**
*
*/
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
* 日期:2012-8-23 上午11:36:12
* 作者:
* 模块:
* 描述:
* 备注:
* ------------------------------------------------------------
* 修改历史
* 序号 日期 修改人 修改原因
*
* 修改备注:
* @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) {
}
}
}
}
客户端
[java] view
plaincopy
/**
*
*/
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 日期:2012-8-23 下午01:47:12
* 作者:
* 模块:
* 描述:
* 备注:
* ------------------------------------------------------------
* 修改历史
* 序号
* 日期
* 修改人
* 修改原因
* 修改备注:
*
* @version
***************************************************************
*/
public class JabberClient {
/**
* 方法名:main 描述: 作者:白鹏飞 日期:2012-8-23 下午01:47:12
*
* @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();
}
}
}
}
这样一个简单地通信就完成了,这里我们要注意现在只能一对一通信。下面我们将使用多线程来实现多客户端通信的例子。
相关文章推荐
- 设置textfeild的属性
- 整理的HTML5 CANVAS 定义、属性和方法
- open_basedir restriction in effect. File() is not within the allowed path(s)
- FreeSWITCH 1.6关于视频通话的一些测试
- android启动另一个app应用
- ViewPagerIndicator简要使用方法
- android系统自带下拉刷新控件的实现
- js判断input是否为空
- OJ 系列之删除字符串中出现次数最少的字符
- 初识《MVC》
- 我看过的
- 数据结构和抽象数据类型
- 瓦片地图黑线彻底解决
- 解决linux下网页页面解析问题
- MSSQL 各种连接-左外连接、右外连接、内连接、全连接
- Android studio 多渠道打包(超简洁版)
- 线程池的实现(c语言)
- Android设计模式之一个例子让你彻底明白工厂模式(Factory Pattern)
- Python: scikit-image canny 边缘检测
- 如何在本地配置域名和ip对应关系