一、什么是Socket通信

Socket通信是一种网络通信协议，用于在计算机之间进行数据传输。它提供了一种可靠的、双向的、面向连接的通信方式。通过Socket，计算机之间可以建立起通信链接，并在连接上发送和接收数据。它可以用于不同的网络协议，如TCP和UDP。
Socket通信在网络编程中应用广泛，可实现客户端和服务器之间的数据传输，允许实时通信和数据交换。它具有灵活性和可扩展性，可用于各种应用领域，包括网络通信、实时数据传输、分布式系统和互联网应用等。

二、虹科工业树莓派应用Socket通信的重要性

在工业领域，Socket通信被广泛应用。虹科工业树莓派作为工业场景下常用设备，结合Socket通信，能够提供了可靠的通信方式，为工业自动化和智能化提供了强大的支持。
– 实时监控与控制：通过Socket通信，工业树莓派可以接收传感器数据、发送控制指令，实时了解工业设备状态，并迅速做出相应的调整和控制。
– 数据采集与分析：通过Socket通信，工业树莓派可以与数据采集服务器或云平台建立连接，将采集到的数据传输到远程存储或分析系统中，实现对工业数据的集中管理和分析，为决策提供准确的数据支持。
– 远程维护与故障排除：Socket通信使得工业树莓派能够与远程维护团队进行远程连接，实现远程维护和故障排除。维护人员可以通过Socket通信远程访问工业树莓派，检查设备状态、进行故障诊断，并远程执行维护操作，减少停机时间和维护成本。
– 分布式控制与协同工作：工业树莓派通过Socket通信可以与其他工业设备或节点进行连接，形成分布式控制系统，实现协同工作和资源共享，从而可以提高工业生产的灵活性、效率和可扩展性。
– 高度灵活性与可定制性：Socket通信为工业树莓派提供了灵活的通信接口，可以根据具体需求进行定制和扩展。工业树莓派可以适应不同的通信协议和数据格式，与各种工业设备和系统进行无缝集成。

三、虹科工业树莓派的Socket应用
在以下测试应用中，虹科工业树莓派作为Socket客户端，PC作为Socket服务器端。虹科工业树莓派通过MODBUS TCP协议采集MODBUS从站数据，并通过Socket通信将数据发送至PC，并保存在MySQL数据库中。

1、客户端（虹科工业树莓派）

#encoding=utf-8  
#-*- coding：utf-8 -*-  
import socket  
from myCtrlLib import *  
  
print("客户端开启") #套接字接口  
mySocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)#设置ip和端口  
host = "192.168.7.2"  
port = 2222  
  
try:  
    mySocket.connect((host, port)) ##连接到服务器  
    print("连接到服务器")  
    while True:  
        msg = readFromName('input_Word_1')  
        mySocket.sendall(msg.encode())  
        print("发送成功")  
except : ##连接不成功，运行最初的ip  
    print ("连接不成功")  

2、服务器端（PC）

# encoding: utf-8  
import socket  
import time  
import pymysql  
  
# 打开数据库连接，参数1：主机名或IP；参数2：用户名；参数3：密码；参数4：数据库名  
db = pymysql.connect(host='127.0.0.1', user='root', password='your password', database='test')  
  
# 使用cursor()创建一个cursor对象  
cursor = db.cursor()  
  
#创建Socket对象  
print("服务端开启")#套接字接口  
mySocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)#设置IP和端口  
  
#绑定IP地址和端口  
host = "192.168.7.2"  
port = 2222     
mySocket.bind((host, port))  
mySocket.listen(10)  
  
# 使用预处理语句创建表  
sql = """CREATE TABLE test( 
id int(8) NOT NULL AUTO_INCREMENT, 
name varchar(50) NOT NULL, 
data varchar(50) NOT NULL, 
PRIMARY KEY (id)    
) ENGINE=MyISAM AUTO_INCREMENT=1 DEFAULT CHARSET=utf8; 
"""  
  
# 使用execute()方法执行SQL语句，如果表存在删除  
cursor.execute("DROP TABLE IF EXISTS test")  
  
# 执行SQL语句  
cursor.execute(sql)  
  
while True:#接收客户端连接  
    print("等待连接….")  
    client,address = mySocket.accept()  
    print("新连接")  
    print("IP is %s" % address[0])  
    print("port is %d\n" % address[1])  
    while True:  
        msg = client.recv(1024)#把接收到的数据进行解码  
        data = msg.decode("utf-8")  
        print("读取完成")  
        # 执行SQL,插入多条数据  
        data = {  
            ("Input_Word_1", data),  
        }  
        try:  
          
            cursor.execute("insert into test(name,data) values (%s,%s)", data)  
  
            # 提交数据  
            db.commit()  
            print("数据插入成功！")  
      
        except Exception as e:  
            # 发生错误时回滚  
            db.rollback()  
            print("数据插入失败:", str(e))  
          
        finally:  
            # 关闭游标和数据库连接  
            cursor.close()  
            db.close()

3、测试效果

a.modbus从站数据

b.数据库

四、总结

虹科工业树莓派结合Socket通信能够实现实时监控与控制、数据采集与分析、远程维护与故障排除，以及分布式控制与协同工作等功能。除此之外，虹科工业树莓派硬件上支持模块化扩展，结合硬件使用，能够在最大程度上满足不同的工业需求。

更多虹科工业树莓派应用&解决方案欢迎扫描下方二维码咨询。