Java Socket实战之一:单线程通信
2024-10-21 23:02:00
转自:http://developer.51cto.com/art/201202/317543.htm
现在做Java直接使用Socket的情况是越来越少,因为有很多的选择可选,比如说可以用spring,其中就可以支持很多种远程连接的操作,另外jboss的remoting也是不错的选择,还有Apache的Mina等等,但是在有些时候一些特殊情况仍然逃脱不了直接写Socket的情况,比如公司内部一些莫名其妙的游戏规则。
废话不说了,下面就看看如果自己写Socket应该怎么做吧。
首先是写一个Server类,这个类用来监听10000端口,并从这个端口接收消息然后输出,当收到“bye”时退出。
package com.googlecode.garbagecan.test.socket.sample1; import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket; public class MyServer {
public static void main(String[] args) throws IOException {
ServerSocket server = new ServerSocket(10000);
Socket socket = server.accept();
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
PrintWriter out = new PrintWriter(socket.getOutputStream()); while (true) {
String msg = in.readLine();
System.out.println(msg);
out.println("Server received " + msg);
out.flush();
if (msg.equals("bye")) {
break;
}
}
socket.close();
}
}
然后是一个Client类,这个类连接上面启动的Server类,然后接收任何用户输入,当遇到回车时发送字符串到Server上,当输入“bye”是退出。
package com.googlecode.garbagecan.test.socket.sample1; import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket; public class MyClient {
public static void main(String[] args) throws Exception {
Socket socket = new Socket("localhost", 10000);
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
PrintWriter out = new PrintWriter(socket.getOutputStream());
BufferedReader reader = new BufferedReader(new InputStreamReader(System.in)); while (true) {
String msg = reader.readLine();
out.println(msg);
out.flush();
if (msg.equals("bye")) {
break;
}
System.out.println(in.readLine());
}
socket.close();
}
}
最后,首先运行MyServer类,然后MyClient类,然后在MyClient的控制台输入任意字符,可以看到当输入bye是server和client都会退出。
最新文章
- Net设计模式实例之桥接模式( Bridge Pattern)
- plain framework 1(简约框架)一款主要用于网络(游戏)开发的C/C++框架 即将开源发布
- JS-JQuery(JSONP)调用WebService跨域若干技术点
- go语言和资料
- XE5 ImageList的BUG?
- Hibernate的关联映射——单向N-1关联
- xcode 路径
- call callb callp区别
- 工业CF卡与商业CF卡对比
- ajax与算法,sql的group处理
- CodeForces 754C Vladik and chat (DP+暴力)
- Spring源码情操陶冶-ComponentScanBeanDefinitionParser文件扫描解析器
- UVA1619 栈维护递增序列
- vue性能
- vue项目使用element ui的Checkbox
- mybatisplus打印sql语句
- PHP拦截器之__set()与__get()的理解与使用方法
- Vue 安装环境创建项目
- 【UVALive】4094 WonderTeam(神结论)
- 计算机应用基础PPT flash作业