本文采用的是读取本地文件，因为没有相机，所以只能够这么操作，基本上类似。

作业中的代码如图：

配置中“作业属性”->“编辑脚本”->“C#脚本”。

作业脚本代码如下：

using System;
using System.Net;
using System.Text;
using System.Net.Sockets;
using System.Threading;
using System.Windows.Forms;
using System.Collections.Generic;
using Cognex.VisionPro;
using Cognex.VisionPro.QuickBuild;public class UserScript : CogJobBaseScript
{//集合可以看似数组，集合的长度是可变得，其元素是object类型//泛型集合时指定了数据类型的集合private object _lock=new object();//定义NetworkStream的泛型集合private List<NetworkStream>_streams = new List<NetworkStream>();//定义TCPClient的泛型集合private List<TcpClient>_clients = new List<TcpClient>();//服务器端监听对象private TcpListener _listener;//连接线程private Thread _connectionThread;//定义Thread泛型集合private List<Thread> _threads=new List<Thread>();//接受数据总长度private long _totalBytes;//作业private CogJob MyJob;#region "When an Acq Fifo Has Been Constructed and Assigned To The Job"// This function is called when a new fifo is assigned to the job.  This usually// occurs when the "Initialize Acquisition" button is pressed on the image source// control.  This function is where you would perform custom setup associated// with the fifo.public override void AcqFifoConstruction(Cognex.VisionPro.ICogAcqFifo fifo){}
#endregion#region "When an Acquisition is About To Be Started"// Called before an acquisition is started for manual and semi-automatic trigger// models.  If "Number of Software Acquisitions Pre-queued" is set to 1 in the// job configuration, then no acquisitions should be in progress when this// function is called.public override void PreAcquisition(){// To let the execution stop in this script when a debugger is attached, uncomment the following lines.// #if DEBUG// if (System.Diagnostics.Debugger.IsAttached) System.Diagnostics.Debugger.Break();// #endif}
#endregion#region "When an Acquisition Has Just Completed"// Called immediately after an acquisition has completed.// Return true if the image should be inspected.// Return false to skip the inspection and acquire another image.public override bool PostAcquisitionRefInfo(ref Cognex.VisionPro.ICogImage image,Cognex.VisionPro.ICogAcqInfo info){// To let the execution stop in this script when a debugger is attached, uncomment the following lines.// #if DEBUG// if (System.Diagnostics.Debugger.IsAttached) System.Diagnostics.Debugger.Break();// #endifreturn true;}
#endregion#region "When the Script is Initialized"//Perform any initialization required by your script here.public override void Initialize(CogJob jobParam){//DO NOT REMOVE - Call the base class implementation first - DO NOT REMOVEbase.Initialize(jobParam);//将当前作业可以复制给MyjobMyJob = jobParam;//开启线程StartThreading();}
#endregion//开启线程实现服务器的端口监听private void StartThreading(){try {_totalBytes = 0;//_connectionThread对象实例化_connectionThread = new System.Threading.Thread(new ThreadStart(ConnectToClient));//线程后台运行_connectionThread.IsBackground = true;//线程开始运行_connectionThread.Start();}catch(Exception ex){MessageBox.Show("线程启动失败");}}//连接到客户端private void ConnectToClient(){try{//开始监听6001端口_listener = new TcpListener(IPAddress.Any, 6001);_listener.Start();}catch(SocketException se){MessageBox.Show("服务器监听失败" + se.Message);StopServer();return;}//监听客户端的连接请求try{for(;;){//等待客户端的连接请求TcpClient client = _listener.AcceptTcpClient();//创建线程开始接受客户端数据Thread t = new Thread(new ParameterizedThreadStart(ReceiveDataFromClient));//线程后台运行t.IsBackground = true;//线程优先级t.Priority = ThreadPriority.AboveNormal;//线程名称t.Name = "Handle Client";//开启线程t.Start(client);//将线程对象添加到泛型集合里_threads.Add(t);//将客户端添加到泛型集合里_clients.Add(client);}}catch(SocketException ex){MessageBox.Show("Socket错误" + ex.Message);}catch(Exception ex){MessageBox.Show("异常错误" + ex.Message);}}//接受客户端传过来的数据public void ReceiveDataFromClient(object clientObject){//定义TcpClient对象并赋值TcpClient client = clientObject as TcpClient;//定义NetworkStream对象并赋值NetworkStream netStream = null;try{//获取客户端的网络数据流netStream = client.GetStream();}catch(Exception ex){if(netStream != null) netStream.Close();MessageBox.Show("异常错误" + ex.Message);return;}if(netStream.CanRead){//将数据流添加到_streams泛型集合里_streams.Add(netStream);try{byte[] receiveBuffer = new byte[512];int bytesReceived;//循环读取客户端发来的数据while((bytesReceived = netStream.Read(receiveBuffer, 0, receiveBuffer.Length)) > 0){if(Encoding.ASCII.GetString(receiveBuffer, 0, bytesReceived) == "start"){MyJob.RunContinuous();//MessageBox.Show("接受到的数据："+Encoding.ASCII.GetString(receiveBuffer,0,bytesReceived);}if(Encoding.ASCII.GetString(receiveBuffer, 0, bytesReceived) == "stop"){MyJob.Stop();//MessageBox.Show("接受到的数据:"+Encoding.ASCII.GetString(receiveBuffer, 0, bytesReceived));}}}catch(Exception ex){MessageBox.Show("异常错误" + ex.Message);}}}//停止服务器private void StopServer(){if(_listener != null){//关闭TCP监听_listener.Stop();//等待服务器线程中断_connectionThread.Join();//关闭所有客户端的网络数据流foreach(NetworkStream s in _streams)s.Close();//清除_streams泛型集合里的内容_streams.Clear();//关闭客户端连接foreach(TcpClient client in _clients)client.Close();//清除_clients泛型集合里的内容_clients.Clear();//等待所有客户端线程中断foreach(Thread t in _threads)t.Join();//清除_threads泛型集合里的内容_threads.Clear();}}}

C# Form界面如下：

代码如下：

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using System.Net;
using System.Net.Sockets;
using System.Threading;namespace TCPClientApplicationProgram
{public partial class Form1 : Form{Socket clientSocket;Thread clientThread;public Form1(){InitializeComponent();//对跨线程的非法错误不检查Control.CheckForIllegalCrossThreadCalls = false;this.IP_textBox1.Text = "127.0.0.1";this.Port_textBox2.Text = "6001";}private void Send_button_Click(object sender, EventArgs e){byte[] data = new byte[1024];//对输入信息进行编码并放到一个字节数组data = Encoding.ASCII.GetBytes(this.Content_textBox3.Text);//向服务器发送信息clientSocket.Send(data, data.Length, SocketFlags.None);}private void ConnectSever_button1_Click(object sender, EventArgs e){if(this.IP_textBox1.Text==""){MessageBox.Show("请输入IP！");return;}//开启一个子线程，连接到服务器clientThread = new Thread(new ThreadStart(ConnectToServer));clientThread.Start();}private void ConnectToServer(){byte[] data = new byte[1024];//网络地址和服务端口的组合称为端点，IPEndPoint类表示这个端口IPEndPoint ipep = new IPEndPoint(IPAddress.Parse(this.IP_textBox1.Text), int.Parse(this.Port_textBox2.Text));//初始化SocketclientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//将套接字与远程服务器地址相连try{//连接到服务器clientSocket.Connect(ipep);}catch(SocketException ex){MessageBox.Show("connect error:" + ex.Message);}}}
}

运行效果：

参考：

蔚来教育企业店