Socket接收的数据用WritePrinter写入打印机被分为若干个文件错误

cxnet

我用Socket方式接收一个tcp数据包存为byte数据，每次接收1024个字节，然后将byte转为16进制进行内容替换后再转为byte数据，再将byte数据用OpenPrinter、StartDocPrinter、StartPagePrinter、WritePrinter、EndPagePrinter、EndDocPrinter、ClosePrinter等Api写入打印机，但现在遇到一个问题，它会把原本同一数据写入到打印机驱动里就变成了若干个1024字节的任务，我是想让它在打印队列里还是一个完整的任务应该怎么做？这个数据可以通过判断接收数据的头部特征十六进制代码52454D4F5445315449就打开打印机句柄并写入打印机队列任务，如果数据里包含结尾特征十六进制代码4A450100001B000000就结束打印并关闭打印机句柄，而没有发现这两个代码的数据就一直让它追加写入同一个打印任务

1. using System.Net.Sockets;
   
2. using System.Net;
   
3. using System.Runtime.InteropServices;
   
4. 
   
5. namespace fsd
   
6. {
   
7.     public partial class Form1 : Form
   
8.     {
   
9.         public Form1()
   
10.         {
    
11.             InitializeComponent();
    
12.         }
    
13. 
    
14.         [StructLayout(LayoutKind.Sequential, CharSet = CharSet.Ansi)]
    
15.         public class DOCINFOA
    
16.         {
    
17.             [MarshalAs(UnmanagedType.LPStr)]
    
18.             public string pDocName;
    
19.             [MarshalAs(UnmanagedType.LPStr)]
    
20.             public string pOutputFile;
    
21.             [MarshalAs(UnmanagedType.LPStr)]
    
22.             public string pDataType;
    
23.         }
    
24.         [DllImport("winspool.Drv", EntryPoint = "OpenPrinterA", SetLastError = true, CharSet = CharSet.Ansi, ExactSpelling = true, CallingConvention = CallingConvention.StdCall)]
    
25.         public static extern bool OpenPrinter([MarshalAs(UnmanagedType.LPStr)] string szPrinter, out IntPtr hPrinter, IntPtr pd);
    
26. 
    
27.         [DllImport("winspool.Drv", EntryPoint = "ClosePrinter", SetLastError = true, ExactSpelling = true, CallingConvention = CallingConvention.StdCall)]
    
28.         public static extern bool ClosePrinter(IntPtr hPrinter);
    
29. 
    
30.         [DllImport("winspool.Drv", EntryPoint = "StartDocPrinterA", SetLastError = true, CharSet = CharSet.Ansi, ExactSpelling = true, CallingConvention = CallingConvention.StdCall)]
    
31.         public static extern bool StartDocPrinter(IntPtr hPrinter, Int32 level, [In, MarshalAs(UnmanagedType.LPStruct)] DOCINFOA di);
    
32. 
    
33.         [DllImport("winspool.Drv", EntryPoint = "EndDocPrinter", SetLastError = true, ExactSpelling = true, CallingConvention = CallingConvention.StdCall)]
    
34.         public static extern bool EndDocPrinter(IntPtr hPrinter);
    
35. 
    
36.         [DllImport("winspool.Drv", EntryPoint = "StartPagePrinter", SetLastError = true, ExactSpelling = true, CallingConvention = CallingConvention.StdCall)]
    
37.         public static extern bool StartPagePrinter(IntPtr hPrinter);
    
38. 
    
39.         [DllImport("winspool.Drv", EntryPoint = "EndPagePrinter", SetLastError = true, ExactSpelling = true, CallingConvention = CallingConvention.StdCall)]
    
40.         public static extern bool EndPagePrinter(IntPtr hPrinter);
    
41. 
    
42.         [DllImport("winspool.Drv", EntryPoint = "WritePrinter", SetLastError = true, ExactSpelling = true, CallingConvention = CallingConvention.StdCall)]
    
43.         public static extern bool WritePrinter(IntPtr hPrinter, IntPtr pBytes, Int32 dwCount, out Int32 dwWritten);
    
44. 
    
45. 
    
46. 
    
47. 
    
48.         private static bool SendBytesToPrinter(string printerName, IntPtr intptrBytes, Int32 count)
    
49.         {
    
50.             Int32 error = 0, written = 0;
    
51.             IntPtr intptrPrinter = new IntPtr(0);
    
52.             DOCINFOA di = new DOCINFOA();
    
53.             bool bSuccess = false;
    
54. 
    
55.             di.pDocName = "Test Document";
    
56.             di.pDataType = "RAW";
    
57. 
    
58.             if (OpenPrinter(printerName.Normalize(), out intptrPrinter, IntPtr.Zero))
    
59.             {
    
60.                 if (StartDocPrinter(intptrPrinter, 1, di))
    
61.                 {
    
62.                     if (StartPagePrinter(intptrPrinter))
    
63.                     {
    
64.                         bSuccess = WritePrinter(intptrPrinter, intptrBytes, count, out written);
    
65.                         EndPagePrinter(intptrPrinter);
    
66.                     }
    
67.                     EndDocPrinter(intptrPrinter);
    
68.                 }
    
69.                 ClosePrinter(intptrPrinter);
    
70.             }
    
71.             if (bSuccess == false)
    
72.             {
    
73.                 error = Marshal.GetLastWin32Error();
    
74.             }
    
75.             return bSuccess;
    
76.         }
    
77.         Socket _socket;
    
78.         Dictionary<string, Socket> dicSocket = new Dictionary<string, Socket>();
    
79. 
    
80.         private void checkBox1_CheckedChanged(object sender, EventArgs e)
    
81.         {
    
82.             if (checkBox1.Checked)
    
83.             {
    
84.                 _socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
    
85.                 IPEndPoint endpoint = new IPEndPoint(IPAddress.Parse("127.0.0.58"), 9178);
    
86.                 try
    
87.                 {
    
88.                     _socket.Bind(endpoint);
    
89. 
    
90.                 }
    
91.                 catch (Exception ee)
    
92.                 {
    
93.                     MessageBox.Show("连接失败");
    
94.                 }
    
95.                 _socket.Listen(10);
    
96. 
    
97. 
    
98.                 while (true)
    
99.                 {
    
100.                     Socket sockClient = _socket.Accept();
     
101.                     while (true)
     
102.                     {
     
103.                         byte[] Receivedata = new byte[1024];
     
104.                         int length = -1;
     
105.                         try
     
106.                         {
     
107.                             length = sockClient.Receive(Receivedata);
     
108.                         }
     
109.                         catch
     
110.                         {
     
111.                             break;
     
112.                         }
     
113. 
     
114.                         if (length == 0)
     
115.                         {
     
116.                             sockClient.Close();
     
117.                             break;
     
118.                         }
     
119.                         else
     
120.                         {
     
121.                             string data = BitConverter.ToString(Receivedata);
     
122.                             data = data.Replace("-", "");                                                         
     
123.                             int Data_head = data.IndexOf("52454D4F5445315449");
     
124.                             int End_data = data.IndexOf("4A450100001B000000");
     
125.                             if (data.Contains("804420FB00144008020820820040411101"))
     
126.                             {
     
127.                                 data = data.Replace("804420FB00144008020820820040411101", "5A4420FB001440080345A33C0040411108");
     
128.                             }
     
129. 
     
130. 
     
131. 
     
132. 
     
133.                             string printer_name = "Printer Name";
     
134.                             byte[] outdata = Enumerable.Range(0, data.Length)
     
135.                                         .Where(x => x % 2 == 0)
     
136.                                         .Select(x => Convert.ToByte(data.Substring(x, 2), 16))
     
137.                                         .ToArray();
     
138.                             IntPtr pUnmanagedBytes = Marshal.AllocCoTaskMem(outdata.Length);
     
139.                             Marshal.Copy(outdata, 0, pUnmanagedBytes, outdata.Length);
     
140. 
     
141.                             if (pUnmanagedBytes != 0)
     
142.                             {
     
143.                                 SendBytesToPrinter(printer_name, pUnmanagedBytes, outdata.Length);
     
144.                             }
     
145.                         }
     
146.                     }
     
147.                 }
     
148.             }
     
149.             else
     
150.             {
     
151.                 _socket.Close();
     
152.             }
     
153.         }
     
154.     }
     
155. 
     
156. }
     

复制代码

cxnet

FishC 发表于 2024-7-20 11:55
哇，这个问题绝对是打破了我的鱼缸。看来您需要解决的是数据接收和处理的问题，以确保它们能够作为一个完整 ...

不能拼接完成再打印，因为拼接完成数据会很大，有些文件大小在1G以上，有的5G大小，这样需要很长的拼接时间，而且会出现内存错误，所以需要边接收边替换边打印

cxnet

FishC 发表于 2024-7-20 12:04
明白了，既然拼接整合成完整数据会引发内存错误，我们需要在接收数据的过程中，以流式处理的方式尽量保 ...

经过你的方法已经成功，如果我想把接收的同一个数据分块分别写入2个或者多个打印机怎么写代码呢？

cxnet

FishC 发表于 2024-7-23 08:16
太好了，很高兴知道之前的方法能够成功！现在，让我们来实现将接收到的同一份数据分块分别写入多个打印 ...

private Dictionary dicSocket = new Dictionary();这一句有问题，需要两个参数

cxnet

FishC 发表于 2024-7-23 08:16
太好了，很高兴知道之前的方法能够成功！现在，让我们来实现将接收到的同一份数据分块分别写入多个打印 ...

当同一数据分块分别写入多个打印机时你这一句代码有问题，缺少2个参数private Dictionary dicSocket = new Dictionary();

cxnet

FishC 发表于 2024-7-23 09:18
抱歉给您带来了困扰！确实，声明一个 `Dictionary` 时需要指定键和值的数据类型。让我们正确地定义这个 ...

这段代码有2个问题

第1个问题是Checkbox取消选择后会在Socket sockClient = _socket.Accept();此出出现错误System.Net.Sockets.SocketException:“一个封锁操作被对 WSACancelBlockingCall 的调用中断。”

第2个问题是，分块打印到多个打印机时，只有打印机名称数组中最后一个打印机是写入完整的数据，其它的打印机只接收到空数据

cxnet

FishC 发表于 2024-7-23 10:11
感谢您的反馈！我们来逐个解决这两个问题。

### 问题 1：Checkbox取消选择后Socket.Accept抛出异常
...

这段代码只是解决了异常问题，但还是和之前一样，只有打印机名称数组里最后一个打印机可以接收到完整的数据，而数组前面所有的打印机只能接收到空数据，我昨天试了很多次和现在一样的效果，始终不知道问题出在哪里