如何进行socket通信

本篇文章为大家展示了如何进行socket通信，内容简明扼要并且容易理解，绝对能使你眼前一亮，通过这篇文章的详细介绍希望你能有所收获。

创新互联网站建设提供从项目策划、软件开发，软件安全维护、网站优化(SEO)、网站分析、效果评估等整套的建站服务，主营业务为网站设计制作、成都做网站，重庆App定制开发以传统方式定制建设网站，并提供域名空间备案等一条龙服务，秉承以专业、用心的态度为用户提供真诚的服务。创新互联深信只要达到每一位用户的要求，就会得到认可，从而选择与我们长期合作。这样，我们也可以走得更远！

一、使用socket实现一对一的简单通信  

socket就是一个开往网络应用必备的功能模块。通过这个模块我们可以自己写程序的server端和client端，可以自己定义server端对外提供服务器的ip地址和端口。学会使用这个模块的之后我们不仅可以开往网络程序，还可以利用socket模块开发出端口扫描的程序。

先看一段创建服务器端的代码

1. # -*- coding: utf-8 -*-

2. import socket

3. import os

5. #定义服务器端启动后要绑定的ip和端口

6. ip_port = ('0.0.0.0',9999)

7. # 创建socket对象并指定连接的网络类型和传输协议

8. sk=sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

9. #绑定ip和端口号

10. sk.bind(ip_port)

11. #启动监听，并设置最多可以通知连入连接数

12. sk.listen(5)

13. #用while使程序一直运行

14. while True:

15.     #print 'server waiting...'

16.     """

17.     进入accpet阻塞状态来等待客户端的连接请求

18.     保存客户端的连接状态和客户端的地址

19.     """

20.     conn,addr = sk.accept()

21.     print addr

22.     #如果有客户端发来请求就每次都只接受1024个字节的内容，注意recv()也是阻塞的

23.     client_data = conn.recv(10240)

24.     #打印从客户端接收到的字符串

25.     print client_data                ----客户端ip地址

26.     #向客户端发送字符串

27.     conn.sendall("I`m server")

28.     #关闭连接

29.     conn.close()

客户端代码

1. # -*- coding: utf-8 -*-

2. import socket
   #指定server端的ip地址和端口号
   ip_port = ('127.0.0.1',9999)
   #创建socket实例，参数不填的话就采用ipv4协议通过tcp传输
   sk = socket.socket()
   #发起连接到server端
   sk.connect(ip_port)
   #给server端发消息
   sk.sendall("I`m client")
   #发送完成后接收server端的反馈
   server_reply = sk.recv(1024)
   #打印server端反馈的信息
   print server_reply
   #关闭连接
   sk.close()

通过以上两段代码的运行，我们就实现了server端与client端的通信

在server端可以到如下运行结果，接收到客户端请求之后又恢复到了等待状态

1. server waiting...

2. I`m client

3. server waiting...

在client端也看到了类似的结果，成功接收到了server端的发来的信息之后退出了程序

点击(此处)折叠或打开

1. I`m server

拓展：实时解析客户端的日志文件并发送至服务端保存

server端改写

1. # -*- coding: utf-8 -*-

2. import socket

3. import os

5. def save_to_txt(addr,data):

6.                 path='/tmp/'+addr+'/slow.log'

7.                 file_path = os.path.split(path)

8.                 if not os.path.exists( file_path[0] ):

9.                         os.makedirs( file_path[0] )

10.                         print '创建目录成功'

11.                 if len(data)>0:

12.                         try:

13.                                 with open( path.encode('utf-8'),'ab' ) as f:

14.                                         data = data+"\n"

15.                                         f.write( data.encode('utf-8') )

16.                                         

17.                         except:

18.                                 print '数据插入失败'

19.                 else:

20.                         print '没有数据'

23. #定义服务器端启动后要绑定的ip和端口

24. ip_port = ('0.0.0.0',9999)

25. # 创建socket对象并指定连接的网络类型和传输协议

26. sk=sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

27. #绑定ip和端口号

28. sk.bind(ip_port)

29. #启动监听，并设置最多可以通知连入连接数

30. sk.listen(5)

31. #用while使程序一直运行

32. while True:

33.     #print 'server waiting...'

34.     """

35.     进入accpet阻塞状态来等待客户端的连接请求

36.     保存客户端的连接状态和客户端的地址

37.     """

38.     conn,addr = sk.accept()

39.     print addr

40.     #如果有客户端发来请求就每次都只接受1024个字节的内容，注意recv()也是阻塞的

41.     client_data = conn.recv(10240)

42.     #打印从客户端接收到的字符串

43.     print client_data

44.     save_to_txt(addr[0],client_data) ----接送并写入日志文件

45.     #向客户端发送字符串

46.     conn.sendall("I`m server")

47.     #关闭连接

48.     conn.close()

client改写

1. # -*- coding: utf-8 -*-
   

2. import socket
   

3. def sendtxt(line):
   

4.     ip_port = ('192.168.2.136',9999)
   

5.     #创建socket实例，参数不填的话就采用ipv4协议通过tcp传输
   

6.     sk = socket.socket()
   

7.     #发起连接到server端
   

8.     sk.connect(ip_port)
   

9.     #给server端发消息
   

10.     sk.sendall(line)
    

11.     #发送完成后接收server端的反馈
    

12.     server_reply = sk.recv(10240)
    

13.     #打印server端反馈的信息
    

14.     print server_reply
    

15.     #关闭连接
    

16.     sk.close()
    

17. 
    

18. 
    

19. import fileinput
    

20. import time
    

21. import os
    

22. 
    

23. target_file = 'log.txt'
    

24. init_flag = True  # 初次加载程序
    

25. 
    

26. record_count = 0
    

27. 
    

28. while True:
    

29.         if init_flag:
    

30.             #读取整个文件
    

31.             # for eachline in fileinput.input(target_file):
    

32.             #    print eachline
    

33.             #    record_count += 1
    

34.             total_count = os.popen('wc -l %s' % target_file).read().split()[0]
    

35.             total_count = int(total_count)
    

36.             record_count = total_count
    

37. 
    

38.             init_flag = False
    

39.         else:
    

40.             #如果总行数小于当前行，那么认为文件更新了，从第一行开始读。
    

41.             total_count = os.popen('wc -l %s' % target_file).read().split()[0]
    

42.             total_count = int(total_count)
    

43.             if total_count < record_count:
    

44.                 record_count = 0
    

45. 
    

46.             for eachline in fileinput.input(target_file):
    

47.                 line_no = fileinput.filelineno()
    

48.                 if line_no > record_count:
    

49.                    if len(eachline.strip('\n')) > 0:
    

50.                        print eachline.strip('\n')
    

51.                        sendtxt(eachline.strip('\n')) --发送

52.                        record_count += 1
    

53.                    else:
    

54.                        sendtxt('        ')
    

55.                        record_count += 1

上述内容就是如何进行socket通信，你们学到知识或技能了吗？如果还想学到更多技能或者丰富自己的知识储备，欢迎关注创新互联行业资讯频道。