文档章节

web项目加入socket

别寒
 别寒
发布于 2015/08/15 14:43
字数 211
阅读 91
收藏 4

    服务端:

public static void startSocket() {
		Socket socket = null;
		BufferedReader br = null;
		PrintWriter pw = null;
		try {

			ServerSocket server = new ServerSocket(9090);
			while (true) {

				socket = server.accept();
//				System.out.println("客户端信息:" + socket.getLocalSocketAddress());

				InputStream in = socket.getInputStream();

				InputStreamReader is = new InputStreamReader(in);
				br = new BufferedReader(is);

				String info = br.readLine();
				System.out.println("接收客户端的信息" + info);
				
				OutputStream out = socket.getOutputStream();
				pw = new PrintWriter(out);
				pw.print("返回数据给客户端");
				pw.flush();

				// 关闭
				in.close();
				is.close();
				br.close();
				
				out.close();
				pw.close();
				
			}
			
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} 
		finally {
			try {
//				pw.close();
//				br.close();
				socket.close();
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		
	}


客户端:

for (int i = 0; i <2; i++) {
			Socket socket = null;
			PrintWriter pw = null;
			BufferedReader br = null;
			try {
			
				socket = new Socket("123.57.150.181", 9090);
				
				OutputStream out = socket.getOutputStream();
//				System.out.println("�������Ϣ��" + socket.getRemoteSocketAddress());
			
				pw = new PrintWriter(out);


//				pw.println("funName=Tick&DeviceId=460040017107640" + i);

//				pw.println("funName=deviceRegister&IMSI=46002012731449");
				pw.println("funName=pathHistory&IMSI=460040017107470&sendingTime=2010-08-24T10:40:40&positions=113.887972,22.717676/&speed=-52446704/+618475291/");


				pw.flush();

				InputStream in = socket.getInputStream();

				br = new BufferedReader(new InputStreamReader(in));
				String info = br.readLine();
				System.out.println(info);

				in.close();
				out.close();
				br.close();
				pw.close();
				socket.close();

			} catch (Exception e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			} finally {
				try {
					pw.close();
					socket.close();
					br.close();
				} catch (IOException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
		}















© 著作权归作者所有

共有 人打赏支持
别寒
粉丝 29
博文 271
码字总数 137605
作品 0
永州
程序员
私信 提问
Djando多环境配置Redis+nginx

在root用户下配置遇到了很多问题,建议在linux 个人用户下配置,会减少很多麻烦。 Redis 1.nginx 安装 启动、停止、重启 OR ** 2.UWSGI 安装 **3.uWSGI和nginx部署Django web client < - > t...

人间四月
2016/09/28
29
0
maven配置resin和debug模式

右键maven项目,在Java Build Path选项的Source选项,选中Output folder 点击Edit按钮,改变maven原来的java文件编译目录,按ok就可以了。 原来的maven的java文件编译后会保存在target目录下...

张升强
2013/11/18
0
0
jfinal 整合netty

@jfinal 我的项目中用jfinal做web开发 80端口,但是有一部分功能需要用到 websocket与浏览器交互。 我用netty开发的web socket service , 8080端口。 我的问题是,当把两个整合在一起的时候...

matthewrod
2015/03/25
1K
5
Phoenix官方教程 (九) Channel

频道是Phoenix中非常exciting和强大的一部分。它让我们能简单地为应用添加软实时特性。频道基于一个简单的想法 - 收发信息。发送者发布关于话题的信息。接收者关注了这个话题,然后他们就能得...

ljzn
2016/08/17
337
0
dreamsfly/weaving-socket-core

#weaving-socket-core weaving-socket 架构的.net core跨平台版本 QQ交流群17375149 新版本更新: weaving-socket PC以及IOT,与安卓项目 点这里 2017-5-3更新新版本。老版本在多协议公用业务...

dreamsfly
2017/05/05
0
0

没有更多内容

加载失败,请刷新页面

加载更多

http协议请求头的意义

GET /day31_Http_306/index.jsp HTTP/1.1: GET请求,请求服务器路径为/hello/index.jsp,协议为1.1 请求头 1.Host:localhost:请求的主机名为localhost2.User-Agent:Mozilla/5.0(Windows NT......

潇潇程序缘
9分钟前
0
0
Netty 简单服务器 (三)

经过对Netty的基础认识,设计模型的初步了解,来写个测试,试试手感 上篇也说到官方推荐我们使用主从线程池模型,那就选择这个模型进行操作 需要操作的步骤: 需要构建两个主从线程组 写一个服务器...

_大侠__
20分钟前
3
0
day02:管道符、shell及环境变量

1、管道符:"|" 用于将前一个指令的输出作为后一个指令的输入,且管道符后面跟的是命令(针对文档的操作):cat less head tail grep cut sort wc uniq tee tr split sed awk等) [root@localho...

芬野de博客
31分钟前
8
0
Kubernetes系列——Kubernetes 组件、对象(二)

一、Kubernetes 组件 介绍了Kubernetes集群所需的各种二进制组件。 Master 组件 Master组件提供集群的管理控制中心。Master组件可以在集群中任何节点上运行。但是为了简单起见,通常在一...

吴伟祥
40分钟前
13
0
Flink-数据流编程模型

1、抽象等级 Flink提供了不同级别的抽象来开发流/批处理应用程序。 1) 低层级的抽象 最低层次的抽象仅仅提供有状态流。它通过Process函数嵌入到DataStream API中。它允许用户自由地处理来自一...

liwei2000
58分钟前
9
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部